Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-3303

Pass partial record metadata to Interceptor onAcknowledgement in case of errors

    XMLWordPrintableJSON

    Details

    • Type: Improvement
    • Status: Resolved
    • Priority: Blocker
    • Resolution: Fixed
    • Affects Version/s: 0.10.0.0
    • Fix Version/s: 0.10.0.0
    • Component/s: None
    • Labels:
      None

      Description

      Currently Interceptor.onAcknowledgement behaves similarly to Callback. If exception occurred and exception is passed to onAcknowledgement, metadata param is set to null.

      However, it would be useful to pass topic, and partition if available to the interceptor so that it knows which topic/partition got an error.

      This is part of KIP-42.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                apovzner Anna Povzner
                Reporter:
                apovzner Anna Povzner
                Reviewer:
                Jun Rao
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: