[KAFKA-2403] Expose offset commit metadata in new consumer

• Type: Sub-task
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 0.9.0.0
• Assignee: Jason Gustafson
• Reporter: Jason Gustafson
• Created: 04/Aug/15 17:10
• Updated: 23/Sep/15 21:07
• Resolved: 23/Sep/15 21:07

Description

The offset commit protocol supports the ability to add user metadata to commits, but this is not yet exposed in the new consumer API. The straightforward way to add it is to create a container for the offset and metadata and adjust the KafkaConsumer API accordingly.

OffsetMetadata {
  long offset;
  String metadata;
}

KafkaConsumer {
  commit(Map<TopicPartition, OffsetMetadata>)
  OffsetMetadata committed(TopicPartition)
}