[ https://issues.apache.org/jira/browse/KAFKA-6434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324830#comment-16324830 ]
Vahid Hashemian edited comment on KAFKA-6434 at 1/13/18 5:18 AM: ----------------------------------------------------------------- [~cabot] This is fixed in the current trunk (by KIP-171) and will land on 1.1.0. It appears though that {{kafka-consumer-groups.sh --list --bootstrap-server localhost:9092}} still does not output such groups because the protocol type for them is not set (the required protocol type by this command is {{consumer}}). [~hachikuji], do you think this is the correct behavior? *Update*: I just came across [KAFKA-6287|https://issues.apache.org/jira/browse/KAFKA-6287] which addresses the issue I mentioned. was (Author: vahid): [~cabot] This is fixed in the current trunk (by KIP-171) and will land on 1.1.0. It appears though that {{kafka-consumer-groups.sh --list --bootstrap-server localhost:9092}} still does not output such groups because the protocol type for them is not set (the required protocol type by this command is {{consumer}}). [~hachikuji], do you think this is the correct behavior? > Kafka-consumer-groups.sh reset-offsets does not work properly for not > existing group > ------------------------------------------------------------------------------------ > > Key: KAFKA-6434 > URL: https://issues.apache.org/jira/browse/KAFKA-6434 > Project: Kafka > Issue Type: Bug > Components: tools > Affects Versions: 0.11.0.2 > Reporter: George Smith > Assignee: Vahid Hashemian > > Our usecase: We are migrating Spark streaming app into Kafka streaming. We > want to continue processing from the last processed offsets of the Spark > streaming app. Therefore we want to define new consumer group (application > id) with given offsets. The new app was not launched yet (we don't want to > make side effects of processing into db) -> new consumer group does not exist. > I was happy to see the updated Kafka-consumer-groups.sh supports > reset-offsets method. Unfortunately it seems it's not working as expected. > {code} > kafka-consumer-groups.sh --reset-offsets --bootstrap-server localhost:9092 > --topic testTopic:0 --group testGROUP --to-offset 10 > Note: This will only show information about consumers that use the Java > consumer API (non-ZooKeeper-based consumers). > TOPIC PARTITION NEW-OFFSET > testTopic 0 10 > {code} > Now I want to check offsets for the group: > {code} > kafka-consumer-groups.sh --describe --bootstrap-server localhost:9092 --group > testGROUP > Error: Consumer group 'testGROUP' does not exist. > {code} > That's strange, isn't it? > On the other side when I use kafka-streams-application-reset.sh - the group > is obviously created - unfortunately this tool does not support given offsets > for partitions (only the beginning is supported) + it does not support > secured Kafka connection... -- This message was sent by Atlassian JIRA (v6.4.14#64029)