> vagrant ssh worker1 Welcome to Ubuntu 14.04.1 LTS (GNU/Linux 3.13.0-43-generic x86_64) * Documentation: https://help.ubuntu.com/ System information as of Thu Jan 15 19:34:05 UTC 2015 System load: 0.19 Processes: 76 Usage of /: 4.0% of 39.34GB Users logged in: 0 Memory usage: 12% IP address for eth0: 10.0.2.15 Swap usage: 0% IP address for eth1: 192.168.50.101 Graph this data and manage this system at: https://landscape.canonical.com/ Get cloud support with Ubuntu Advantage Cloud Guest: http://www.ubuntu.com/business/services/cloud Last login: Thu Jan 15 19:34:05 2015 from 10.0.2.2 vagrant@worker1:~$ cd /opt/kafka vagrant@worker1:/opt/kafka$ bin/kafka-topics.sh --zookeeper 192.168.50.11:2181 --create --replication-factor 2 --partitions 2 --topic t1 Created topic "t1". vagrant@worker1:/opt/kafka$ bin/kafka-topics.sh --zookeeper 192.168.50.11:2181 --create --replication-factor 2 --partitions 2 --topic t2 Created topic "t2". vagrant@worker1:/opt/kafka$ bin/kafka-topics.sh --zookeeper 192.168.50.11:2181 --create --replication-factor 2 --partitions 2 --topic t3 Created topic "t3". vagrant@worker1:/opt/kafka$ bin/kafka-topics.sh --zookeeper 192.168.50.11:2181 --create --replication-factor 2 --partitions 2 --topic t4 Created topic "t4". vagrant@worker1:/opt/kafka$ bin/kafka-topics.sh --zookeeper 192.168.50.11:2181 --list t1 t2 t3 t4 vagrant@worker1:/opt/kafka$ bin/kafka-topics.sh --zookeeper 192.168.50.11:2181 --describe Topic:t1 PartitionCount:2 ReplicationFactor:2 Configs: Topic: t1 Partition: 0 Leader: 1 Replicas: 1,2 Isr: 1,2 Topic: t1 Partition: 1 Leader: 2 Replicas: 2,1 Isr: 2,1 Topic:t2 PartitionCount:2 ReplicationFactor:2 Configs: Topic: t2 Partition: 0 Leader: 1 Replicas: 1,2 Isr: 1,2 Topic: t2 Partition: 1 Leader: 2 Replicas: 2,1 Isr: 2,1 Topic:t3 PartitionCount:2 ReplicationFactor:2 Configs: Topic: t3 Partition: 0 Leader: 1 Replicas: 1,2 Isr: 1,2 Topic: t3 Partition: 1 Leader: 2 Replicas: 2,1 Isr: 2,1 Topic:t4 PartitionCount:2 ReplicationFactor:2 Configs: Topic: t4 Partition: 0 Leader: 1 Replicas: 1,2 Isr: 1,2 Topic: t4 Partition: 1 Leader: 2 Replicas: 2,1 Isr: 2,1 vagrant@worker1:/opt/kafka$ bin/kafka-console-producer.sh --broker-list 192.168.50.51:9092,192.168.50.52:9092 --topic t1 [2015-01-15 20:11:04,479] WARN Property topic is not valid (kafka.utils.VerifiableProperties) hi hey ^Cvagrant@worker1:/opt/kafka$ bin/kafka-console-producer.sh --broker-list 192.168.50.51:9092,192.168.50.52:9092 --topic t2 [2015-01-15 20:11:29,052] WARN Property topic is not valid (kafka.utils.VerifiableProperties) hey2 ^Cvagrant@worker1:/opt/kafka$ bin/kafka-console-producer.sh --broker-list 192.168.50.51:9092,192.168.50.52:9092 --topic t3 [2015-01-15 20:11:41,097] WARN Property topic is not valid (kafka.utils.VerifiableProperties) hey3 ^Cvagrant@worker1:/opt/kafka$ bin/kafka-console-producer.sh --broker-list 192.168.50.51:9092,192.168.50.52:9092 --topic t4 [2015-01-15 20:11:56,329] WARN Property topic is not valid (kafka.utils.VerifiableProperties) hey4 ^Cvagrant@worker1:/opt/kafka$ bin/kafka-console-consumer.sh --zookeeper 192.168.50.11:2181 --topic t1,t2 --consumer.config ~/g1.properties[1] 4811 vagrant@worker1:/opt/kafka$ vagrant@worker1:/opt/kafka$ bin/kafka-console-consumer.sh --zookeeper 192.168.50.11:2181 --topic t2,t3 --consumer.config ~/g2.properties &[2] 4837 vagrant@worker1:/opt/kafka$ vagrant@worker1:/opt/kafka$ bin/kafka-console-consumer.sh --zookeeper 192.168.50.11:2181 --topic t1,t2,t3 --consumer.config ~/g3.properties & [3] 4863 vagrant@worker1:/opt/kafka$ vagrant@worker1:/opt/kafka$ bin/kafka-console-consumer.sh --zookeeper 192.168.50.11:2181 --topic t1,t2,t3 --consumer.config ~/g4.properties & [4] 4889 vagrant@worker1:/opt/kafka$ vagrant@worker1:/opt/kafka$ bin/kafka-console-consumer.sh --zookeeper 192.168.50.11:2181 --topic t4 --consumer.config ~/g5.properties & [5] 4915 vagrant@worker1:/opt/kafka$ vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --list g1 g2 g3 g4 g5 vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g1 GROUP TOPIC PID CURRENT OFFSET LOG SIZE LAG OWNER g1 , t1 , 0 , 0 , 0 , 0 g1_worker1-1421352732340-84581a23-0 g1 , t1 , 1 , 2 , 2 , 0 g1_worker1-1421352732340-84581a23-0 GROUP TOPIC PID CURRENT OFFSET LOG SIZE LAG OWNER g1 , t2 , 0 , 1 , 1 , 0 g1_worker1-1421352732340-84581a23-0 g1 , t2 , 1 , 0 , 0 , 0 g1_worker1-1421352732340-84581a23-0 vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g1 --config channelSocketTimeoutMs=400 --config channelRetryBackoffMsOpt=200 GROUP TOPIC PID CURRENT OFFSET LOG SIZE LAG OWNER g1 , t1 , 0 , 0 , 0 , 0 g1_worker1-1421352732340-84581a23-0 g1 , t1 , 1 , 2 , 2 , 0 g1_worker1-1421352732340-84581a23-0 GROUP TOPIC PID CURRENT OFFSET LOG SIZE LAG OWNER g1 , t2 , 0 , 1 , 1 , 0 g1_worker1-1421352732340-84581a23-0 g1 , t2 , 1 , 0 , 0 , 0 g1_worker1-1421352732340-84581a23-0 vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g2 GROUP TOPIC PID CURRENT OFFSET LOG SIZE LAG OWNER g2 , t2 , 0 , 1 , 1 , 0 g2_worker1-1421352740070-4d192722-0 g2 , t2 , 1 , 0 , 0 , 0 g2_worker1-1421352740070-4d192722-0 GROUP TOPIC PID CURRENT OFFSET LOG SIZE LAG OWNER g2 , t3 , 0 , 0 , 0 , 0 g2_worker1-1421352740070-4d192722-0 g2 , t3 , 1 , 1 , 1 , 0 g2_worker1-1421352740070-4d192722-0 vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g3 GROUP TOPIC PID CURRENT OFFSET LOG SIZE LAG OWNER g3 , t1 , 0 , 0 , 0 , 0 g3_worker1-1421352745369-f2ff96f6-0 g3 , t1 , 1 , 2 , 2 , 0 g3_worker1-1421352745369-f2ff96f6-0 GROUP TOPIC PID CURRENT OFFSET LOG SIZE LAG OWNER g3 , t2 , 0 , 1 , 1 , 0 g3_worker1-1421352745369-f2ff96f6-0 g3 , t2 , 1 , 0 , 0 , 0 g3_worker1-1421352745369-f2ff96f6-0 GROUP TOPIC PID CURRENT OFFSET LOG SIZE LAG OWNER g3 , t3 , 0 , 0 , 0 , 0 g3_worker1-1421352745369-f2ff96f6-0 g3 , t3 , 1 , 1 , 1 , 0 g3_worker1-1421352745369-f2ff96f6-0 vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g4 GROUP TOPIC PID CURRENT OFFSET LOG SIZE LAG OWNER g4 , t1 , 0 , 0 , 0 , 0 g4_worker1-1421352751720-8641df77-0 g4 , t1 , 1 , 2 , 2 , 0 g4_worker1-1421352751720-8641df77-0 GROUP TOPIC PID CURRENT OFFSET LOG SIZE LAG OWNER g4 , t2 , 0 , 1 , 1 , 0 g4_worker1-1421352751720-8641df77-0 g4 , t2 , 1 , 0 , 0 , 0 g4_worker1-1421352751720-8641df77-0 GROUP TOPIC PID CURRENT OFFSET LOG SIZE LAG OWNER g4 , t3 , 0 , 0 , 0 , 0 g4_worker1-1421352751720-8641df77-0 g4 , t3 , 1 , 1 , 1 , 0 g4_worker1-1421352751720-8641df77-0 vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g5 GROUP TOPIC PID CURRENT OFFSET LOG SIZE LAG OWNER g5 , t4 , 0 , 1 , 1 , 0 g5_worker1-1421352757284-1b8fe5e8-0 g5 , t4 , 1 , 0 , 0 , 0 g5_worker1-1421352757284-1b8fe5e8-0 vagrant@worker1:/opt/kafka$ jobs [1] Running bin/kafka-console-consumer.sh --zookeeper 192.168.50.11:2181 --topic t1,t2 --consumer.config ~/g1.properties & [2] Running bin/kafka-console-consumer.sh --zookeeper 192.168.50.11:2181 --topic t2,t3 --consumer.config ~/g2.properties & [3] Running bin/kafka-console-consumer.sh --zookeeper 192.168.50.11:2181 --topic t1,t2,t3 --consumer.config ~/g3.properties & [4]- Running bin/kafka-console-consumer.sh --zookeeper 192.168.50.11:2181 --topic t1,t2,t3 --consumer.config ~/g4.properties & [5]+ Running bin/kafka-console-consumer.sh --zookeeper 192.168.50.11:2181 --topic t4 --consumer.config ~/g5.properties & vagrant@worker1:/opt/kafka$ fg 1 bin/kafka-console-consumer.sh --zookeeper 192.168.50.11:2181 --topic t1,t2 --consumer.config ~/g1.properties ^CConsumed 0 messages vagrant@worker1:/opt/kafka$ fg 2 bin/kafka-console-consumer.sh --zookeeper 192.168.50.11:2181 --topic t2,t3 --consumer.config ~/g2.properties ^CConsumed 0 messages vagrant@worker1:/opt/kafka$ fg 3 bin/kafka-console-consumer.sh --zookeeper 192.168.50.11:2181 --topic t1,t2,t3 --consumer.config ~/g3.properties ^CConsumed 0 messages vagrant@worker1:/opt/kafka$ fg 4 bin/kafka-console-consumer.sh --zookeeper 192.168.50.11:2181 --topic t1,t2,t3 --consumer.config ~/g4.properties ^CConsumed 0 messages vagrant@worker1:/opt/kafka$ fg 5 bin/kafka-console-consumer.sh --zookeeper 192.168.50.11:2181 --topic t4 --consumer.config ~/g5.properties ^CConsumed 0 messages vagrant@worker1:/opt/kafka$ jobs vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --delete --group g1 --group g5 Deleted all consumer group information for group g1 in zookeeper. Deleted all consumer group information for group g5 in zookeeper. vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --list g2 g3 g4 vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g1 Error while executing consumer group command org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g1/owners org.I0Itec.zkclient.exception.ZkNoNodeException: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g1/owners at org.I0Itec.zkclient.exception.ZkException.create(ZkException.java:47) at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:685) at org.I0Itec.zkclient.ZkClient.getChildren(ZkClient.java:413) at org.I0Itec.zkclient.ZkClient.getChildren(ZkClient.java:409) at kafka.utils.ZkUtils$.getTopicsByConsumerGroup(ZkUtils.scala:758) at kafka.admin.ConsumerGroupCommand$.describe(ConsumerGroupCommand.scala:81) at kafka.admin.ConsumerGroupCommand$.main(ConsumerGroupCommand.scala:56) at kafka.admin.ConsumerGroupCommand.main(ConsumerGroupCommand.scala) Caused by: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g1/owners at org.apache.zookeeper.KeeperException.create(KeeperException.java:111) at org.apache.zookeeper.KeeperException.create(KeeperException.java:51) at org.apache.zookeeper.ZooKeeper.getChildren(ZooKeeper.java:1472) at org.apache.zookeeper.ZooKeeper.getChildren(ZooKeeper.java:1500) at org.I0Itec.zkclient.ZkConnection.getChildren(ZkConnection.java:99) at org.I0Itec.zkclient.ZkClient$2.call(ZkClient.java:416) at org.I0Itec.zkclient.ZkClient$2.call(ZkClient.java:413) at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675) ... 6 more vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g2 GROUP TOPIC PID CURRENT OFFSET LOG SIZE LAG OWNER g2 , t2 , 0 , 1 , 1 , 0 none g2 , t2 , 1 , 0 , 0 , 0 none GROUP TOPIC PID CURRENT OFFSET LOG SIZE LAG OWNER g2 , t3 , 0 , 0 , 0 , 0 none g2 , t3 , 1 , 1 , 1 , 0 none vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g3 GROUP TOPIC PID CURRENT OFFSET LOG SIZE LAG OWNER g3 , t1 , 0 , 0 , 0 , 0 none g3 , t1 , 1 , 2 , 2 , 0 none GROUP TOPIC PID CURRENT OFFSET LOG SIZE LAG OWNER g3 , t2 , 0 , 1 , 1 , 0 none g3 , t2 , 1 , 0 , 0 , 0 none GROUP TOPIC PID CURRENT OFFSET LOG SIZE LAG OWNER g3 , t3 , 0 , 0 , 0 , 0 none g3 , t3 , 1 , 1 , 1 , 0 none vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g4 GROUP TOPIC PID CURRENT OFFSET LOG SIZE LAG OWNER g4 , t1 , 0 , 0 , 0 , 0 none g4 , t1 , 1 , 2 , 2 , 0 none GROUP TOPIC PID CURRENT OFFSET LOG SIZE LAG OWNER g4 , t2 , 0 , 1 , 1 , 0 none g4 , t2 , 1 , 0 , 0 , 0 none GROUP TOPIC PID CURRENT OFFSET LOG SIZE LAG OWNER g4 , t3 , 0 , 0 , 0 , 0 none g4 , t3 , 1 , 1 , 1 , 0 none vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g5 Error while executing consumer group command org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g5/owners org.I0Itec.zkclient.exception.ZkNoNodeException: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g5/owners at org.I0Itec.zkclient.exception.ZkException.create(ZkException.java:47) at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:685) at org.I0Itec.zkclient.ZkClient.getChildren(ZkClient.java:413) at org.I0Itec.zkclient.ZkClient.getChildren(ZkClient.java:409) at kafka.utils.ZkUtils$.getTopicsByConsumerGroup(ZkUtils.scala:758) at kafka.admin.ConsumerGroupCommand$.describe(ConsumerGroupCommand.scala:81) at kafka.admin.ConsumerGroupCommand$.main(ConsumerGroupCommand.scala:56) at kafka.admin.ConsumerGroupCommand.main(ConsumerGroupCommand.scala) Caused by: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g5/owners at org.apache.zookeeper.KeeperException.create(KeeperException.java:111) at org.apache.zookeeper.KeeperException.create(KeeperException.java:51) at org.apache.zookeeper.ZooKeeper.getChildren(ZooKeeper.java:1472) at org.apache.zookeeper.ZooKeeper.getChildren(ZooKeeper.java:1500) at org.I0Itec.zkclient.ZkConnection.getChildren(ZkConnection.java:99) at org.I0Itec.zkclient.ZkClient$2.call(ZkClient.java:416) at org.I0Itec.zkclient.ZkClient$2.call(ZkClient.java:413) at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675) ... 6 more vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --delete-for-topic --group g3 --group g4 --topic t2 Deleted consumer group information for group g3 for topic t2 in zookeeper. Deleted consumer group information for group g4 for topic t2 in zookeeper. vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --list g2 g3 g4 vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g1 Error while executing consumer group command org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g1/owners org.I0Itec.zkclient.exception.ZkNoNodeException: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g1/owners at org.I0Itec.zkclient.exception.ZkException.create(ZkException.java:47) at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:685) at org.I0Itec.zkclient.ZkClient.getChildren(ZkClient.java:413) at org.I0Itec.zkclient.ZkClient.getChildren(ZkClient.java:409) at kafka.utils.ZkUtils$.getTopicsByConsumerGroup(ZkUtils.scala:758) at kafka.admin.ConsumerGroupCommand$.describe(ConsumerGroupCommand.scala:81) at kafka.admin.ConsumerGroupCommand$.main(ConsumerGroupCommand.scala:56) at kafka.admin.ConsumerGroupCommand.main(ConsumerGroupCommand.scala) Caused by: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g1/owners at org.apache.zookeeper.KeeperException.create(KeeperException.java:111) at org.apache.zookeeper.KeeperException.create(KeeperException.java:51) at org.apache.zookeeper.ZooKeeper.getChildren(ZooKeeper.java:1472) at org.apache.zookeeper.ZooKeeper.getChildren(ZooKeeper.java:1500) at org.I0Itec.zkclient.ZkConnection.getChildren(ZkConnection.java:99) at org.I0Itec.zkclient.ZkClient$2.call(ZkClient.java:416) at org.I0Itec.zkclient.ZkClient$2.call(ZkClient.java:413) at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675) ... 6 more vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g2 GROUP TOPIC PID CURRENT OFFSET LOG SIZE LAG OWNER g2 , t2 , 0 , 1 , 1 , 0 none g2 , t2 , 1 , 0 , 0 , 0 none GROUP TOPIC PID CURRENT OFFSET LOG SIZE LAG OWNER g2 , t3 , 0 , 0 , 0 , 0 none g2 , t3 , 1 , 1 , 1 , 0 none vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g3 GROUP TOPIC PID CURRENT OFFSET LOG SIZE LAG OWNER g3 , t1 , 0 , 0 , 0 , 0 none g3 , t1 , 1 , 2 , 2 , 0 none GROUP TOPIC PID CURRENT OFFSET LOG SIZE LAG OWNER g3 , t3 , 0 , 0 , 0 , 0 none g3 , t3 , 1 , 1 , 1 , 0 none vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g4 GROUP TOPIC PID CURRENT OFFSET LOG SIZE LAG OWNER g4 , t1 , 0 , 0 , 0 , 0 none g4 , t1 , 1 , 2 , 2 , 0 none GROUP TOPIC PID CURRENT OFFSET LOG SIZE LAG OWNER g4 , t3 , 0 , 0 , 0 , 0 none g4 , t3 , 1 , 1 , 1 , 0 none vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g5 Error while executing consumer group command org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g5/owners org.I0Itec.zkclient.exception.ZkNoNodeException: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g5/owners at org.I0Itec.zkclient.exception.ZkException.create(ZkException.java:47) at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:685) at org.I0Itec.zkclient.ZkClient.getChildren(ZkClient.java:413) at org.I0Itec.zkclient.ZkClient.getChildren(ZkClient.java:409) at kafka.utils.ZkUtils$.getTopicsByConsumerGroup(ZkUtils.scala:758) at kafka.admin.ConsumerGroupCommand$.describe(ConsumerGroupCommand.scala:81) at kafka.admin.ConsumerGroupCommand$.main(ConsumerGroupCommand.scala:56) at kafka.admin.ConsumerGroupCommand.main(ConsumerGroupCommand.scala) Caused by: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g5/owners at org.apache.zookeeper.KeeperException.create(KeeperException.java:111) at org.apache.zookeeper.KeeperException.create(KeeperException.java:51) at org.apache.zookeeper.ZooKeeper.getChildren(ZooKeeper.java:1472) at org.apache.zookeeper.ZooKeeper.getChildren(ZooKeeper.java:1500) at org.I0Itec.zkclient.ZkConnection.getChildren(ZkConnection.java:99) at org.I0Itec.zkclient.ZkClient$2.call(ZkClient.java:416) at org.I0Itec.zkclient.ZkClient$2.call(ZkClient.java:413) at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675) ... 6 more vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --delete-all-for-topic --topic t1 --delete-all-for-topic failed because topic t1 still exists. vagrant@worker1:/opt/kafka$ bin/kafka-topics.sh --zookeeper 192.168.50.11:2181 --delete --topic t1 Topic t1 is marked for deletion. Note: This will have no impact if delete.topic.enable is not set to true. vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --delete-all-for-topic --topic t1 Deleted all consumer group information for topic t1 in zookeeper. vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --list g2 g3 g4 vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g1 Error while executing consumer group command org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g1/owners org.I0Itec.zkclient.exception.ZkNoNodeException: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g1/owners at org.I0Itec.zkclient.exception.ZkException.create(ZkException.java:47) at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:685) at org.I0Itec.zkclient.ZkClient.getChildren(ZkClient.java:413) at org.I0Itec.zkclient.ZkClient.getChildren(ZkClient.java:409) at kafka.utils.ZkUtils$.getTopicsByConsumerGroup(ZkUtils.scala:758) at kafka.admin.ConsumerGroupCommand$.describe(ConsumerGroupCommand.scala:81) at kafka.admin.ConsumerGroupCommand$.main(ConsumerGroupCommand.scala:56) at kafka.admin.ConsumerGroupCommand.main(ConsumerGroupCommand.scala) Caused by: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g1/owners at org.apache.zookeeper.KeeperException.create(KeeperException.java:111) at org.apache.zookeeper.KeeperException.create(KeeperException.java:51) at org.apache.zookeeper.ZooKeeper.getChildren(ZooKeeper.java:1472) at org.apache.zookeeper.ZooKeeper.getChildren(ZooKeeper.java:1500) at org.I0Itec.zkclient.ZkConnection.getChildren(ZkConnection.java:99) at org.I0Itec.zkclient.ZkClient$2.call(ZkClient.java:416) at org.I0Itec.zkclient.ZkClient$2.call(ZkClient.java:413) at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675) ... 6 more vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g2 GROUP TOPIC PID CURRENT OFFSET LOG SIZE LAG OWNER g2 , t2 , 0 , 1 , 1 , 0 none g2 , t2 , 1 , 0 , 0 , 0 none GROUP TOPIC PID CURRENT OFFSET LOG SIZE LAG OWNER g2 , t3 , 0 , 0 , 0 , 0 none g2 , t3 , 1 , 1 , 1 , 0 none vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g3 GROUP TOPIC PID CURRENT OFFSET LOG SIZE LAG OWNER g3 , t3 , 0 , 0 , 0 , 0 none g3 , t3 , 1 , 1 , 1 , 0 none vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g4 GROUP TOPIC PID CURRENT OFFSET LOG SIZE LAG OWNER g4 , t3 , 0 , 0 , 0 , 0 none g4 , t3 , 1 , 1 , 1 , 0 none vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g5 Error while executing consumer group command org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g5/owners org.I0Itec.zkclient.exception.ZkNoNodeException: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g5/owners at org.I0Itec.zkclient.exception.ZkException.create(ZkException.java:47) at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:685) at org.I0Itec.zkclient.ZkClient.getChildren(ZkClient.java:413) at org.I0Itec.zkclient.ZkClient.getChildren(ZkClient.java:409) at kafka.utils.ZkUtils$.getTopicsByConsumerGroup(ZkUtils.scala:758) at kafka.admin.ConsumerGroupCommand$.describe(ConsumerGroupCommand.scala:81) at kafka.admin.ConsumerGroupCommand$.main(ConsumerGroupCommand.scala:56) at kafka.admin.ConsumerGroupCommand.main(ConsumerGroupCommand.scala) Caused by: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g5/owners at org.apache.zookeeper.KeeperException.create(KeeperException.java:111) at org.apache.zookeeper.KeeperException.create(KeeperException.java:51) at org.apache.zookeeper.ZooKeeper.getChildren(ZooKeeper.java:1472) at org.apache.zookeeper.ZooKeeper.getChildren(ZooKeeper.java:1500) at org.I0Itec.zkclient.ZkConnection.getChildren(ZkConnection.java:99) at org.I0Itec.zkclient.ZkClient$2.call(ZkClient.java:416) at org.I0Itec.zkclient.ZkClient$2.call(ZkClient.java:413) at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675) ... 6 more vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --delete-all-for-topic --topic t3 --force-delete Deleted all consumer group information for topic t3 in zookeeper. vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --list g2 vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g1 Error while executing consumer group command org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g1/owners org.I0Itec.zkclient.exception.ZkNoNodeException: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g1/owners at org.I0Itec.zkclient.exception.ZkException.create(ZkException.java:47) at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:685) at org.I0Itec.zkclient.ZkClient.getChildren(ZkClient.java:413) at org.I0Itec.zkclient.ZkClient.getChildren(ZkClient.java:409) at kafka.utils.ZkUtils$.getTopicsByConsumerGroup(ZkUtils.scala:758) at kafka.admin.ConsumerGroupCommand$.describe(ConsumerGroupCommand.scala:81) at kafka.admin.ConsumerGroupCommand$.main(ConsumerGroupCommand.scala:56) at kafka.admin.ConsumerGroupCommand.main(ConsumerGroupCommand.scala) Caused by: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g1/owners at org.apache.zookeeper.KeeperException.create(KeeperException.java:111) at org.apache.zookeeper.KeeperException.create(KeeperException.java:51) at org.apache.zookeeper.ZooKeeper.getChildren(ZooKeeper.java:1472) at org.apache.zookeeper.ZooKeeper.getChildren(ZooKeeper.java:1500) at org.I0Itec.zkclient.ZkConnection.getChildren(ZkConnection.java:99) at org.I0Itec.zkclient.ZkClient$2.call(ZkClient.java:416) at org.I0Itec.zkclient.ZkClient$2.call(ZkClient.java:413) at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675) ... 6 more vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g2 GROUP TOPIC PID CURRENT OFFSET LOG SIZE LAG OWNER g2 , t2 , 0 , 1 , 1 , 0 none g2 , t2 , 1 , 0 , 0 , 0 none vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g3 Error while executing consumer group command org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g3/owners org.I0Itec.zkclient.exception.ZkNoNodeException: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g3/owners at org.I0Itec.zkclient.exception.ZkException.create(ZkException.java:47) at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:685) at org.I0Itec.zkclient.ZkClient.getChildren(ZkClient.java:413) at org.I0Itec.zkclient.ZkClient.getChildren(ZkClient.java:409) at kafka.utils.ZkUtils$.getTopicsByConsumerGroup(ZkUtils.scala:758) at kafka.admin.ConsumerGroupCommand$.describe(ConsumerGroupCommand.scala:81) at kafka.admin.ConsumerGroupCommand$.main(ConsumerGroupCommand.scala:56) at kafka.admin.ConsumerGroupCommand.main(ConsumerGroupCommand.scala) Caused by: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g3/owners at org.apache.zookeeper.KeeperException.create(KeeperException.java:111) at org.apache.zookeeper.KeeperException.create(KeeperException.java:51) at org.apache.zookeeper.ZooKeeper.getChildren(ZooKeeper.java:1472) at org.apache.zookeeper.ZooKeeper.getChildren(ZooKeeper.java:1500) at org.I0Itec.zkclient.ZkConnection.getChildren(ZkConnection.java:99) at org.I0Itec.zkclient.ZkClient$2.call(ZkClient.java:416) at org.I0Itec.zkclient.ZkClient$2.call(ZkClient.java:413) at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675) ... 6 more vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g4 Error while executing consumer group command org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g4/owners org.I0Itec.zkclient.exception.ZkNoNodeException: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g4/owners at org.I0Itec.zkclient.exception.ZkException.create(ZkException.java:47) at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:685) at org.I0Itec.zkclient.ZkClient.getChildren(ZkClient.java:413) at org.I0Itec.zkclient.ZkClient.getChildren(ZkClient.java:409) at kafka.utils.ZkUtils$.getTopicsByConsumerGroup(ZkUtils.scala:758) at kafka.admin.ConsumerGroupCommand$.describe(ConsumerGroupCommand.scala:81) at kafka.admin.ConsumerGroupCommand$.main(ConsumerGroupCommand.scala:56) at kafka.admin.ConsumerGroupCommand.main(ConsumerGroupCommand.scala) Caused by: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g4/owners at org.apache.zookeeper.KeeperException.create(KeeperException.java:111) at org.apache.zookeeper.KeeperException.create(KeeperException.java:51) at org.apache.zookeeper.ZooKeeper.getChildren(ZooKeeper.java:1472) at org.apache.zookeeper.ZooKeeper.getChildren(ZooKeeper.java:1500) at org.I0Itec.zkclient.ZkConnection.getChildren(ZkConnection.java:99) at org.I0Itec.zkclient.ZkClient$2.call(ZkClient.java:416) at org.I0Itec.zkclient.ZkClient$2.call(ZkClient.java:413) at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675) ... 6 more vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g5 Error while executing consumer group command org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g5/owners org.I0Itec.zkclient.exception.ZkNoNodeException: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g5/owners at org.I0Itec.zkclient.exception.ZkException.create(ZkException.java:47) at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:685) at org.I0Itec.zkclient.ZkClient.getChildren(ZkClient.java:413) at org.I0Itec.zkclient.ZkClient.getChildren(ZkClient.java:409) at kafka.utils.ZkUtils$.getTopicsByConsumerGroup(ZkUtils.scala:758) at kafka.admin.ConsumerGroupCommand$.describe(ConsumerGroupCommand.scala:81) at kafka.admin.ConsumerGroupCommand$.main(ConsumerGroupCommand.scala:56) at kafka.admin.ConsumerGroupCommand.main(ConsumerGroupCommand.scala) Caused by: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g5/owners at org.apache.zookeeper.KeeperException.create(KeeperException.java:111) at org.apache.zookeeper.KeeperException.create(KeeperException.java:51) at org.apache.zookeeper.ZooKeeper.getChildren(ZooKeeper.java:1472) at org.apache.zookeeper.ZooKeeper.getChildren(ZooKeeper.java:1500) at org.I0Itec.zkclient.ZkConnection.getChildren(ZkConnection.java:99) at org.I0Itec.zkclient.ZkClient$2.call(ZkClient.java:416) at org.I0Itec.zkclient.ZkClient$2.call(ZkClient.java:413) at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675) ... 6 more vagrant@worker1:/opt/kafka$