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)
