Jason Gustafson created KAFKA-2403: -------------------------------------- Summary: Expose offset commit metadata in new consumer Key: KAFKA-2403 URL: https://issues.apache.org/jira/browse/KAFKA-2403 Project: Kafka Issue Type: Improvement Reporter: Jason Gustafson Priority: Minor
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. {code} OffsetMetadata { long offset; String metadata; } KafkaConsumer { commit(Map<TopicPartition, OffsetMetadata>) OffsetMetadata committed(TopicPartition) } {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)