Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

The new InitProducerId API accepts either a user-configured transactional Id or a consumer group Id and the set of assigned partitionsa generation id. When a consumer group is provided, the transaction coordinator will check whether there are any ongoing transactions that include the assigned partitions. If there are, these transactions will be aborted and the corresponding producers will be fenced by bumping their epochs. Once transactions are complete, the call will return.

...