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: 2 Replicas: 2,1 Isr: 2,1 Topic: t1 Partition: 1 Leader: 1 Replicas: 1,2 Isr: 1,2 Topic:t2 PartitionCount:2 ReplicationFactor:2 Configs: Topic: t2 Partition: 0 Leader: 2 Replicas: 2,1 Isr: 2,1 Topic: t2 Partition: 1 Leader: 1 Replicas: 1,2 Isr: 1,2 Topic:t3 PartitionCount:2 ReplicationFactor:2 Configs: Topic: t3 Partition: 0 Leader: 2 Replicas: 2,1 Isr: 2,1 Topic: t3 Partition: 1 Leader: 1 Replicas: 1,2 Isr: 1,2 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-producer-perf-test.sh --broker-list 192.168.50.51:9092,192.168.50.52:9092 --topic t1,t2,t3,t4 --messages 250000 --message-size 200 --vary-message-size start.time, end.time, compression, message.size, batch.size, total.data.sent.in.MB, MB.sec, total.data.sent.in.nMsg, nMsg.sec 2015-02-05 10:13:52:127, 2015-02-05 10:14:27:630, 0, 200, 200, 95.80, 2.6983, 1000000, 28166.6338 vagrant@worker1:/opt/kafka$ bin/kafka-console-consumer.sh --zookeeper 192.168.50.11:2181 --topic t1,t2 --consumer.config ~/g1.properties & [1] 4594 vagrant@worker1:/opt/kafka$ bin/kafka-console-consumer.sh --zookeeper 192.168.50.11:2181 --topic t2,t3 --consumer.config ~/g2.properties & [2] 4596 vagrant@worker1:/opt/kafka$ bin/kafka-console-consumer.sh --zookeeper 192.168.50.11:2181 --topic t1,t2,t3 --consumer.config ~/g3.properties & [3] 4600 vagrant@worker1:/opt/kafka$ bin/kafka-console-consumer.sh --zookeeper 192.168.50.11:2181 --topic t1,t2,t3 --consumer.config ~/g4.properties & [4] 4606 vagrant@worker1:/opt/kafka$ bin/kafka-console-consumer.sh --zookeeper 192.168.50.11:2181 --topic t4 --consumer.config ~/g5.properties & [5] 4614 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 Could not fetch offset from zookeeper for group g1 partition [t1,0] due to org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g1/offsets/t1/0. Could not fetch offset from zookeeper for group g1 partition [t1,1] due to org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g1/offsets/t1/1. GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g1, t1, 0, unknown, 125000, unknown, g1_worker1-1423131276944-c3cc786f-0 g1, t1, 1, unknown, 125000, unknown, g1_worker1-1423131276944-c3cc786f-0 Could not fetch offset from zookeeper for group g1 partition [t2,0] due to org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g1/offsets/t2/0. Could not fetch offset from zookeeper for group g1 partition [t2,1] due to org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g1/offsets/t2/1. GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g1, t2, 0, unknown, 125000, unknown, g1_worker1-1423131276944-c3cc786f-0 g1, t2, 1, unknown, 125000, unknown, g1_worker1-1423131276944-c3cc786f-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 Could not fetch offset from zookeeper for group g1 partition [t1,0] due to org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g1/offsets/t1/0. Could not fetch offset from zookeeper for group g1 partition [t1,1] due to org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g1/offsets/t1/1. GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g1, t1, 0, unknown, 125000, unknown, g1_worker1-1423131276944-c3cc786f-0 g1, t1, 1, unknown, 125000, unknown, g1_worker1-1423131276944-c3cc786f-0 Could not fetch offset from zookeeper for group g1 partition [t2,0] due to org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g1/offsets/t2/0. Could not fetch offset from zookeeper for group g1 partition [t2,1] due to org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g1/offsets/t2/1. GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g1, t2, 0, unknown, 125000, unknown, g1_worker1-1423131276944-c3cc786f-0 g1, t2, 1, unknown, 125000, unknown, g1_worker1-1423131276944-c3cc786f-0 vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g2 Could not fetch offset from zookeeper for group g2 partition [t2,0] due to org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g2/offsets/t2/0. Could not fetch offset from zookeeper for group g2 partition [t2,1] due to org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g2/offsets/t2/1. GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g2, t2, 0, unknown, 125000, unknown, g2_worker1-1423131276917-69905e98-0 g2, t2, 1, unknown, 125000, unknown, g2_worker1-1423131276917-69905e98-0 Could not fetch offset from zookeeper for group g2 partition [t3,0] due to org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g2/offsets/t3/0. Could not fetch offset from zookeeper for group g2 partition [t3,1] due to org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g2/offsets/t3/1. GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g2, t3, 0, unknown, 125000, unknown, g2_worker1-1423131276917-69905e98-0 g2, t3, 1, unknown, 125000, unknown, g2_worker1-1423131276917-69905e98-0 vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g3 Could not fetch offset from zookeeper for group g3 partition [t1,0] due to org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g3/offsets/t1/0. Could not fetch offset from zookeeper for group g3 partition [t1,1] due to org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g3/offsets/t1/1. GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g3, t1, 0, unknown, 125000, unknown, g3_worker1-1423131276957-4b1b4d44-0 g3, t1, 1, unknown, 125000, unknown, g3_worker1-1423131276957-4b1b4d44-0 Could not fetch offset from zookeeper for group g3 partition [t2,0] due to org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g3/offsets/t2/0. Could not fetch offset from zookeeper for group g3 partition [t2,1] due to org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g3/offsets/t2/1. GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g3, t2, 0, unknown, 125000, unknown, g3_worker1-1423131276957-4b1b4d44-0 g3, t2, 1, unknown, 125000, unknown, g3_worker1-1423131276957-4b1b4d44-0 Could not fetch offset from zookeeper for group g3 partition [t3,0] due to org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g3/offsets/t3/0. Could not fetch offset from zookeeper for group g3 partition [t3,1] due to org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g3/offsets/t3/1. GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g3, t3, 0, unknown, 125000, unknown, g3_worker1-1423131276957-4b1b4d44-0 g3, t3, 1, unknown, 125000, unknown, g3_worker1-1423131276957-4b1b4d44-0 vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g4 Could not fetch offset from zookeeper for group g4 partition [t1,0] due to org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g4/offsets/t1/0. Could not fetch offset from zookeeper for group g4 partition [t1,1] due to org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g4/offsets/t1/1. GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g4, t1, 0, unknown, 125000, unknown, g4_worker1-1423131276974-fc8a103b-0 g4, t1, 1, unknown, 125000, unknown, g4_worker1-1423131276974-fc8a103b-0 Could not fetch offset from zookeeper for group g4 partition [t2,0] due to org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g4/offsets/t2/0. Could not fetch offset from zookeeper for group g4 partition [t2,1] due to org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g4/offsets/t2/1. GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g4, t2, 0, unknown, 125000, unknown, g4_worker1-1423131276974-fc8a103b-0 g4, t2, 1, unknown, 125000, unknown, g4_worker1-1423131276974-fc8a103b-0 Could not fetch offset from zookeeper for group g4 partition [t3,0] due to org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g4/offsets/t3/0. Could not fetch offset from zookeeper for group g4 partition [t3,1] due to org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g4/offsets/t3/1. GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g4, t3, 0, unknown, 125000, unknown, g4_worker1-1423131276974-fc8a103b-0 g4, t3, 1, unknown, 125000, unknown, g4_worker1-1423131276974-fc8a103b-0 vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g5 Could not fetch offset from zookeeper for group g5 partition [t4,0] due to org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g5/offsets/t4/0. Could not fetch offset from zookeeper for group g5 partition [t4,1] due to org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/g5/offsets/t4/1. GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g5, t4, 0, unknown, 125000, unknown, g5_worker1-1423131276982-f9452622-0 g5, t4, 1, unknown, 125000, unknown, g5_worker1-1423131276982-f9452622-0 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, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g1, t1, 0, 125000, 125000, 0, g1_worker1-1423131276944-c3cc786f-0 g1, t1, 1, 125000, 125000, 0, g1_worker1-1423131276944-c3cc786f-0 GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g1, t2, 0, 125000, 125000, 0, g1_worker1-1423131276944-c3cc786f-0 g1, t2, 1, 125000, 125000, 0, g1_worker1-1423131276944-c3cc786f-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, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g1, t1, 0, 125000, 125000, 0, g1_worker1-1423131276944-c3cc786f-0 g1, t1, 1, 125000, 125000, 0, g1_worker1-1423131276944-c3cc786f-0 GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g1, t2, 0, 125000, 125000, 0, g1_worker1-1423131276944-c3cc786f-0 g1, t2, 1, 125000, 125000, 0, g1_worker1-1423131276944-c3cc786f-0 vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g2 GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g2, t2, 0, 125000, 125000, 0, g2_worker1-1423131276917-69905e98-0 g2, t2, 1, 125000, 125000, 0, g2_worker1-1423131276917-69905e98-0 GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g2, t3, 0, 125000, 125000, 0, g2_worker1-1423131276917-69905e98-0 g2, t3, 1, 125000, 125000, 0, g2_worker1-1423131276917-69905e98-0 vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g3 GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g3, t1, 0, 125000, 125000, 0, g3_worker1-1423131276957-4b1b4d44-0 g3, t1, 1, 125000, 125000, 0, g3_worker1-1423131276957-4b1b4d44-0 GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g3, t2, 0, 125000, 125000, 0, g3_worker1-1423131276957-4b1b4d44-0 g3, t2, 1, 125000, 125000, 0, g3_worker1-1423131276957-4b1b4d44-0 GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g3, t3, 0, 125000, 125000, 0, g3_worker1-1423131276957-4b1b4d44-0 g3, t3, 1, 125000, 125000, 0, g3_worker1-1423131276957-4b1b4d44-0 vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g4 GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g4, t1, 0, 125000, 125000, 0, g4_worker1-1423131276974-fc8a103b-0 g4, t1, 1, 125000, 125000, 0, g4_worker1-1423131276974-fc8a103b-0 GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g4, t2, 0, 125000, 125000, 0, g4_worker1-1423131276974-fc8a103b-0 g4, t2, 1, 125000, 125000, 0, g4_worker1-1423131276974-fc8a103b-0 GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g4, t3, 0, 125000, 125000, 0, g4_worker1-1423131276974-fc8a103b-0 g4, t3, 1, 125000, 125000, 0, g4_worker1-1423131276974-fc8a103b-0 vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g5 GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g5, t4, 0, 125000, 125000, 0, g5_worker1-1423131276982-f9452622-0 g5, t4, 1, 125000, 125000, 0, g5_worker1-1423131276982-f9452622-0 vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --delete --group g1 --group g5 Delete for group g1 failed because its consumers are still active. Delete for group g5 failed because its consumers are still active. 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, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g1, t1, 0, 125000, 125000, 0, g1_worker1-1423131276944-c3cc786f-0 g1, t1, 1, 125000, 125000, 0, g1_worker1-1423131276944-c3cc786f-0 GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g1, t2, 0, 125000, 125000, 0, g1_worker1-1423131276944-c3cc786f-0 g1, t2, 1, 125000, 125000, 0, g1_worker1-1423131276944-c3cc786f-0 vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g2 GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g2, t2, 0, 125000, 125000, 0, g2_worker1-1423131276917-69905e98-0 g2, t2, 1, 125000, 125000, 0, g2_worker1-1423131276917-69905e98-0 GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g2, t3, 0, 125000, 125000, 0, g2_worker1-1423131276917-69905e98-0 g2, t3, 1, 125000, 125000, 0, g2_worker1-1423131276917-69905e98-0 vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g3 GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g3, t1, 0, 125000, 125000, 0, g3_worker1-1423131276957-4b1b4d44-0 g3, t1, 1, 125000, 125000, 0, g3_worker1-1423131276957-4b1b4d44-0 GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g3, t2, 0, 125000, 125000, 0, g3_worker1-1423131276957-4b1b4d44-0 g3, t2, 1, 125000, 125000, 0, g3_worker1-1423131276957-4b1b4d44-0 GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g3, t3, 0, 125000, 125000, 0, g3_worker1-1423131276957-4b1b4d44-0 g3, t3, 1, 125000, 125000, 0, g3_worker1-1423131276957-4b1b4d44-0 vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g4 GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g4, t1, 0, 125000, 125000, 0, g4_worker1-1423131276974-fc8a103b-0 g4, t1, 1, 125000, 125000, 0, g4_worker1-1423131276974-fc8a103b-0 GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g4, t2, 0, 125000, 125000, 0, g4_worker1-1423131276974-fc8a103b-0 g4, t2, 1, 125000, 125000, 0, g4_worker1-1423131276974-fc8a103b-0 GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g4, t3, 0, 125000, 125000, 0, g4_worker1-1423131276974-fc8a103b-0 g4, t3, 1, 125000, 125000, 0, g4_worker1-1423131276974-fc8a103b-0 vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g5 GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g5, t4, 0, 125000, 125000, 0, g5_worker1-1423131276982-f9452622-0 g5, t4, 1, 125000, 125000, 0, g5_worker1-1423131276982-f9452622-0 vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --delete --group g3 --group g4 --topic t2 Delete for group g3 topic t2 failed because its consumers are still active. Delete for group g4 topic t2 failed because its consumers are still active. 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, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g1, t1, 0, 125000, 125000, 0, g1_worker1-1423131276944-c3cc786f-0 g1, t1, 1, 125000, 125000, 0, g1_worker1-1423131276944-c3cc786f-0 GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g1, t2, 0, 125000, 125000, 0, g1_worker1-1423131276944-c3cc786f-0 g1, t2, 1, 125000, 125000, 0, g1_worker1-1423131276944-c3cc786f-0 vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g2 GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g2, t2, 0, 125000, 125000, 0, g2_worker1-1423131276917-69905e98-0 g2, t2, 1, 125000, 125000, 0, g2_worker1-1423131276917-69905e98-0 GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g2, t3, 0, 125000, 125000, 0, g2_worker1-1423131276917-69905e98-0 g2, t3, 1, 125000, 125000, 0, g2_worker1-1423131276917-69905e98-0 vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g3 GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g3, t1, 0, 125000, 125000, 0, g3_worker1-1423131276957-4b1b4d44-0 g3, t1, 1, 125000, 125000, 0, g3_worker1-1423131276957-4b1b4d44-0 GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g3, t2, 0, 125000, 125000, 0, g3_worker1-1423131276957-4b1b4d44-0 g3, t2, 1, 125000, 125000, 0, g3_worker1-1423131276957-4b1b4d44-0 GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g3, t3, 0, 125000, 125000, 0, g3_worker1-1423131276957-4b1b4d44-0 g3, t3, 1, 125000, 125000, 0, g3_worker1-1423131276957-4b1b4d44-0 vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g4 GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g4, t1, 0, 125000, 125000, 0, g4_worker1-1423131276974-fc8a103b-0 g4, t1, 1, 125000, 125000, 0, g4_worker1-1423131276974-fc8a103b-0 GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g4, t2, 0, 125000, 125000, 0, g4_worker1-1423131276974-fc8a103b-0 g4, t2, 1, 125000, 125000, 0, g4_worker1-1423131276974-fc8a103b-0 GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g4, t3, 0, 125000, 125000, 0, g4_worker1-1423131276974-fc8a103b-0 g4, t3, 1, 125000, 125000, 0, g4_worker1-1423131276974-fc8a103b-0 vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g5 GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g5, t4, 0, 125000, 125000, 0, g5_worker1-1423131276982-f9452622-0 g5, t4, 1, 125000, 125000, 0, g5_worker1-1423131276982-f9452622-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 No topic available for consumer group provided vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g2 GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g2, t2, 0, 125000, 125000, 0, none g2, t2, 1, 125000, 125000, 0, none GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g2, t3, 0, 125000, 125000, 0, none g2, t3, 1, 125000, 125000, 0, none vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g3 GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g3, t1, 0, 125000, 125000, 0, none g3, t1, 1, 125000, 125000, 0, none GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g3, t2, 0, 125000, 125000, 0, none g3, t2, 1, 125000, 125000, 0, none GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g3, t3, 0, 125000, 125000, 0, none g3, t3, 1, 125000, 125000, 0, none vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g4 GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g4, t1, 0, 125000, 125000, 0, none g4, t1, 1, 125000, 125000, 0, none GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g4, t2, 0, 125000, 125000, 0, none g4, t2, 1, 125000, 125000, 0, none GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g4, t3, 0, 125000, 125000, 0, none g4, t3, 1, 125000, 125000, 0, none vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g5 No topic available for consumer group provided vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --delete --group g3 --group g4 --topic t2 Deleted consumer group information for group g3 topic t2 in zookeeper. Deleted consumer group information for group g4 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 No topic available for consumer group provided vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g2 GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g2, t2, 0, 125000, 125000, 0, none g2, t2, 1, 125000, 125000, 0, none GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g2, t3, 0, 125000, 125000, 0, none g2, t3, 1, 125000, 125000, 0, none vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g3 GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g3, t1, 0, 125000, 125000, 0, none g3, t1, 1, 125000, 125000, 0, none GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g3, t3, 0, 125000, 125000, 0, none g3, t3, 1, 125000, 125000, 0, none vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g4 GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g4, t1, 0, 125000, 125000, 0, none g4, t1, 1, 125000, 125000, 0, none GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g4, t3, 0, 125000, 125000, 0, none g4, t3, 1, 125000, 125000, 0, none vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g5 No topic available for consumer group provided vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --delete --topic t1 Deleted consumer group information for all inactive consumer groups 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 No topic available for consumer group provided vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g2 GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g2, t2, 0, 125000, 125000, 0, none g2, t2, 1, 125000, 125000, 0, none GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g2, t3, 0, 125000, 125000, 0, none g2, t3, 1, 125000, 125000, 0, none vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g3 GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g3, t3, 0, 125000, 125000, 0, none g3, t3, 1, 125000, 125000, 0, none vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g4 GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER g4, t3, 0, 125000, 125000, 0, none g4, t3, 1, 125000, 125000, 0, none vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --describe --group g5 No topic available for consumer group provided vagrant@worker1:/opt/kafka$