AssignorConfiguration¶

Creating Instance¶

AssignorConfiguration takes the following to be created:

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:

AssignorConfiguration looks up a ReferenceContainer when created.

The ReferenceContainer is used in the following:

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:

CopartitionedTopicsEnforcer copartitionedTopicsEnforcer()

copartitionedTopicsEnforcer creates a new CopartitionedTopicsEnforcer (with the logPrefix).

copartitionedTopicsEnforcer is used when:

InternalTopicManager internalTopicManager()

internalTopicManager creates a new InternalTopicManager.

internalTopicManager is used when: