You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Gustav Westling (JIRA)" <ji...@apache.org> on 2017/11/02 13:45:01 UTC

[jira] [Created] (KAFKA-6158) CONSUMER-ID and HOST values are concatenated if the CONSUMER-ID is > 50 chars

Gustav Westling created KAFKA-6158:
--------------------------------------

             Summary: 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
            Reporter: Gustav Westling


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)