Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-6158

CONSUMER-ID and HOST values are concatenated if the CONSUMER-ID is > 50 chars

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Trivial
    • Resolution: Fixed
    • 0.11.0.0, 1.0.0
    • 1.1.0
    • clients
    • None

    Description

      Using the command:

      ./kafka-consumer-groups.sh --bootstrap-server=localhost:9092 --describe --group foo-group
      

      If the CONSUMER-ID is too long the delimiter between CONSUMER-ID and HOST disappears.

      Output:

      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
      

      Expected output:

      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
      

      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.

      Attachments

        Issue Links

          Activity

            People

              vahid Vahid Hashemian
              zegl Gustav Westling
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: