THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Code Block |
|---|
interface Producer {
/**
* This API shall be called for consumer group aware transactional producers.
*/
void initTransactions(Consumer<byte[], byte[]> consumer); // NEW
/**
* No longer need to pass in the consumer group id in a case where we already get access to the consumer state.
*/
void sendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata> offsets) throws ProducerFencedException, IllegalGenerationException; // NEW
} |
Here we introduced an intermediate data structure `GroupAssignment` just to make the evolvement easier in case we need to add more identification info during transaction init stage. There are two main differences in the behavior of this API and the pre-existing `initTransactions`:
...