Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-5527 Idempotent/transactional Producer part 2 (KIP-98)
  3. KAFKA-5270

TransactionManager should send and `AddOffsetsToTxn` request only once per group per transaction

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Open
    • Major
    • Resolution: Unresolved
    • None
    • None
    • clients, core, producer

    Description

      Currently, we send the `AddOffsetsToTxn` request unconditionally every time, even if we receive multiple sendOffsets for the same group. We could keep track of the added groups in the TransactionManager and not resend this RPC multiple times for the same transaction as the subsequent instances add no new information.

      Attachments

        Issue Links

          Activity

            People

              Unassigned Unassigned
              apurva Apurva Mehta
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated: