Skip to content

AssignorConfiguration

Creating Instance

AssignorConfiguration takes the following to be created:

  • Configuration Properties

While being created, AssignorConfiguration creates a new LogContext with the following log prefix (based on client.id):

stream-thread [client.id]

AssignorConfiguration uses the given configs to look up __reference.container.instance__ internal property to be the ReferenceContainer.

AssignorConfiguration...FIXME (INTERNAL_TASK_ASSIGNOR_CLASS)


AssignorConfiguration is created when:

  • StreamsPartitionAssignor is requested to configure

ReferenceContainer

AssignorConfiguration looks up a ReferenceContainer when created.

The ReferenceContainer is used in the following:

rebalanceProtocol

RebalanceProtocol rebalanceProtocol()

rebalanceProtocol takes the value of upgrade.from configuration property (from the StreamsConfig).

Unless upgrade.from is defined, rebalanceProtocol prints out the following INFO message to the logs and returns RebalanceProtocol.COOPERATIVE.

Cooperative rebalancing enabled now

With upgrade.from defined, rebalanceProtocol...FIXME

rebalanceProtocol is used when:

  • StreamsPartitionAssignor is requested to configure

CopartitionedTopicsEnforcer

CopartitionedTopicsEnforcer copartitionedTopicsEnforcer()

copartitionedTopicsEnforcer creates a new CopartitionedTopicsEnforcer (with the logPrefix).

copartitionedTopicsEnforcer is used when:

  • StreamsPartitionAssignor is requested to configure

InternalTopicManager

InternalTopicManager internalTopicManager()

internalTopicManager creates a new InternalTopicManager.

internalTopicManager is used when:

  • StreamsPartitionAssignor is requested to configure
Back to top