THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Code Block | ||||
|---|---|---|---|---|
| ||||
public static final String TRANSACTIONAL_GROUP_ID = "transactional.group.id"; |
And attempt to deprecate following APIs sendOffset API which is using consumer group id:
| Code Block | ||||
|---|---|---|---|---|
| ||||
void sendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata> offsets, String consumerGroupId); // DEPRECATED
void sendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata> offsets); // NEW |
The key to this proposal is allowing a single transaction coordinator to see the assignments of all members in the group. It can then maintain the invariant that only one producer is allowed to make progress at any time for a particular input partition. To enable this, we need two protocol changes. First we need to update the FindCoordinator API to support lookup of the transaction coordinator using the consumer group Id. Second, we need to extend the InitProducerId API to support consumer group aware initialization.
...