You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2017/12/01 22:50:00 UTC
[jira] [Commented] (KAFKA-6158) CONSUMER-ID and HOST values are
concatenated if the CONSUMER-ID is > 50 chars
[ https://issues.apache.org/jira/browse/KAFKA-6158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16275131#comment-16275131 ]
Vahid Hashemian commented on KAFKA-6158:
----------------------------------------
A fix has been proposed for this issue as part of PR# [4271|https://github.com/apache/kafka/pull/4271].
> CONSUMER-ID and HOST values are concatenated if the CONSUMER-ID is > 50 chars
> -----------------------------------------------------------------------------
>
> Key: KAFKA-6158
> URL: https://issues.apache.org/jira/browse/KAFKA-6158
> Project: Kafka
> Issue Type: Bug
> Components: clients
> Affects Versions: 0.11.0.0, 1.0.0
> Reporter: Gustav Westling
> Assignee: Vahid Hashemian
> Priority: Trivial
> Fix For: 1.1.0
>
>
> Using the command:
> {noformat}
> ./kafka-consumer-groups.sh --bootstrap-server=localhost:9092 --describe --group foo-group
> {noformat}
> If the CONSUMER-ID is too long the delimiter between CONSUMER-ID and HOST disappears.
> Output:
> {noformat}
> TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID HOST CLIENT-ID
> foobar-1 14 8948049 8948663 614 default-6697bb36-bf03-46e4-8f3e-4ef987177834-StreamThread-1-consumer-7c0345f5-4806-4957-be26-eb4b3bd6a9dc/10.2.3.40 default-6697bb36-bf03-46e4-8f3e-4ef987177834-StreamThread-1-consumer
> {noformat}
> Expected output:
> {noformat}
> TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID HOST CLIENT-ID
> foobar-1 14 8948049 8948663 614 default-6697bb36-bf03-46e4-8f3e-4ef987177834-StreamThread-1-consumer-7c0345f5-4806-4957-be26-eb4b3bd6a9dc /10.2.3.40 default-6697bb36-bf03-46e4-8f3e-4ef987177834-StreamThread-1-consumer
> {noformat}
> I suspect that the formatting rules are incorrect https://github.com/apache/kafka/blob/0.11.0/core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala#L137.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)