You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Jiangjie Qin (JIRA)" <ji...@apache.org> on 2015/08/04 22:39:05 UTC
[jira] [Commented] (KAFKA-2403) Expose offset commit metadata in
new consumer
[ https://issues.apache.org/jira/browse/KAFKA-2403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14654318#comment-14654318 ]
Jiangjie Qin commented on KAFKA-2403:
-------------------------------------
Can we put this as a sub task of KAFKA-2387, just for better tracking over the new consumer API?
> 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)