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 --list
t1
t2
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: 1	Replicas: 1,2	Isr: 1,2
	Topic: t2	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 --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-10 22:04:09:183, 2015-02-10 22:04:26:946, 0, 200, 200, 47.90, 2.6964, 500000, 28148.3984
vagrant@worker1:/opt/kafka$ bin/kafka-console-consumer.sh --zookeeper 192.168.50.11:2181 --topic t1,t2 --consumer.config ~/g1.properties &
[1] 4503
vagrant@worker1:/opt/kafka$ 
vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --list
g1
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-1423605871163-5533737a-0
g1, t1, 1, 125000, 125000, 0, g1_worker1-1423605871163-5533737a-0
GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER
g1, t2, 0, 125000, 125000, 0, g1_worker1-1423605871163-5533737a-0
g1, t2, 1, 125000, 125000, 0, g1_worker1-1423605871163-5533737a-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 &
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$ jobs
vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --list
g1
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, none
g1, t1, 1, 125000, 125000, 0, none
GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER
g1, t2, 0, 125000, 125000, 0, none
g1, t2, 1, 125000, 125000, 0, none
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-topics.sh --zookeeper 192.168.50.11:2181 --list
__consumer_offsets
t2
vagrant@worker1:/opt/kafka$ bin/kafka-consumer-groups.sh --zookeeper 192.168.50.11:2181 --list
g1
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
GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER
g1, t2, 0, 125000, 125000, 0, none
g1, t2, 1, 125000, 125000, 0, none
vagrant@worker1:/opt/kafka$ bin/zookeeper-shell.sh 192.168.50.11:2181
Connecting to 192.168.50.11:2181
Welcome to ZooKeeper!
JLine support is disabled

WATCHER::

WatchedEvent state:SyncConnected type:None path:null
get /consumers/g1/offsets/t1/0
125000
cZxid = 0x4b
ctime = Tue Feb 10 22:05:31 UTC 2015
mZxid = 0x4b
mtime = Tue Feb 10 22:05:31 UTC 2015
pZxid = 0x4b
cversion = 0
dataVersion = 0
aclVersion = 0
ephemeralOwner = 0x0
dataLength = 6
numChildren = 0
get /consumers/g1/offsets/t1/1
125000
cZxid = 0x4e
ctime = Tue Feb 10 22:05:31 UTC 2015
mZxid = 0x4e
mtime = Tue Feb 10 22:05:31 UTC 2015
pZxid = 0x4e
cversion = 0
dataVersion = 0
aclVersion = 0
ephemeralOwner = 0x0
dataLength = 6
numChildren = 0