kafka-jira mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Gustav Westling (JIRA)" <j...@apache.org>
Subject [jira] [Created] (KAFKA-6158) CONSUMER-ID and HOST values are concatenated if the CONSUMER-ID is > 50 chars
Date Thu, 02 Nov 2017 13:45:01 GMT
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)

Mime
View raw message