[KAFKA-3303] Pass partial record metadata to Interceptor onAcknowledgement in case of errors

• Type: Improvement
• Status: Resolved
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 0.10.0.0
• Fix Version/s: 0.10.0.0
• Assignee: Anna Povzner
• Reporter: Anna Povzner
• Reviewer: Jun Rao
• Created: 29/Feb/16 21:13
• Updated: 17/Mar/16 00:29
• Resolved: 17/Mar/16 00:29

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.

Issue Links

• mentioned in: Page Loading...