You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/23 23:07:04 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=14905259#comment-14905259 ] 

ASF GitHub Bot commented on KAFKA-2403:
---------------------------------------

Github user asfgit closed the pull request at:

    https://github.com/apache/kafka/pull/119


> Expose offset commit metadata in new consumer
> ---------------------------------------------
>
>                 Key: KAFKA-2403
>                 URL: https://issues.apache.org/jira/browse/KAFKA-2403
>             Project: Kafka
>          Issue Type: Sub-task
>            Reporter: Jason Gustafson
>            Assignee: Jason Gustafson
>            Priority: Minor
>             Fix For: 0.9.0.0
>
>
> 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)