[
https://issues.apache.org/jira/browse/KAFKA-7141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16538400#comment-16538400
]
Bohdana Panchenko commented on KAFKA-7141:
------------------------------------------
Steps to reproduce the issue:
I am using Windows and Docker Client for Windows. Kafka broker is running as a
part of the Landoop distribution [https://github.com/Landoop/fast-data-dev.]
Setup looks like this
h4. Kafka 1.0.1-L0 @ Landoop's Apache Kafka Distribution
1× Broker, 1× Schema Registry, 1× Connect Distributed Worker, 1× REST Proxy, 1×
Zookeeper
My Alpakka Kafka connector client and my scala producer are running in other
docker containers - all are in the custom bridge network on my local dev
machine.
I can see my topic in the landoop topic ui and all the messages submitted by my
scala producer. My alpakka consumer processes them happily and delegates
offsets committing to the alpakka library ( {color:#d04437}_enable.auto.commit
= false and
https://doc.akka.io/docs/akka-stream-kafka/current/consumer.html#offset-storage-in-kafka-committing_){color}.
1) start fast-data-dev broker, any producer, alpakka consumer - all in separate
docker containers. Start console consumer from the kafka command line.
2) Send message, verify it has been received from both consumers.
3) Describe both consumers - and compare the output of the describe command for
the console consumer with the output for the alpakka consumer.
What do you mean by " after manually committing offsets"?
I am using _enable.auto.commit = false -_ is that not enough?
> kafka-consumer-group doesn't describe existing group
> ----------------------------------------------------
>
> Key: KAFKA-7141
> URL: https://issues.apache.org/jira/browse/KAFKA-7141
> Project: Kafka
> Issue Type: Bug
> Components: admin
> Affects Versions: 0.11.0.0, 1.0.1
> Reporter: Bohdana Panchenko
> Priority: Major
>
> I am running two consumers: akka-stream-kafka consumer with standard config
> section as described in the
> [https://doc.akka.io/docs/akka-stream-kafka/current/consumer.html] and
> kafka-console-consumer.
> akka-stream-kafka consumer configuration looks like this
> {color:#333333}_akka.kafka.consumer{_{color}
> {color:#333333} _kafka-clients{_{color}
> {color:#333333} _group.id = "myakkastreamkafka-1"_{color}
> {color:#333333} _enable.auto.commit = false_{color}
> }
> {color:#333333} }{color}
>
> I am able to see the both groups with the command
>
> *kafka-consumer-groups --bootstrap-server 127.0.0.1:9092 --list*
> _Note: This will not show information about old Zookeeper-based consumers._
>
> _myakkastreamkafka-1_
> _console-consumer-57171_
> {color:#333333}I am able to view details about the console consumer
> group{color}
> *kafka-consumer-groups --describe --bootstrap-server 127.0.0.1:9092 --group
> console-consumer-57171*
> _{color:#205081}Note: This will not show information about old
> Zookeeper-based consumers.{color}_
> _{color:#205081}TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID
> HOST CLIENT-ID{color}_
> _{color:#205081}STREAM-TEST 0 0 0 0
> consumer-1-6b928e07-196a-4322-9928-068681617878 /172.19.0.4 consumer-1{color}_
> {color:#333333}But the command to describe my akka stream consumer gives me
> empty output:{color}
> *kafka-consumer-groups --describe --bootstrap-server 127.0.0.1:9092 --group
> myakkastreamkafka-1*
> {color:#205081}_Note: This will not show information about old
> Zookeeper-based consumers._{color}
> {color:#205081}_TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID
> HOST CLIENT-ID_{color}
>
> {color:#333333}That is strange. Can you please check the issue?{color}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
