kafka基本操作

kafka版本

kafka_2.11-0.11.0.1

配置server.properties

broker.id： 唯一，填数字
host.name：唯一，填计算机名
zookeeper.connect=（ip1:port，ip:port）

先启动zookeeper，再启动kafka-server

1
bin/kafka-server-start.sh config/server.properties

创建topic

1
2
3
4
5
6
#create
kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1  --topic mykafka
# list
kafka-topics.sh --list --zookeeper localhost:2181
# details
kafka-topics.sh --describe --zookeeper localhost:2181

启动生产者

1
2
kafka-console-producer.sh --brokelist localhost:9092 --topic mykafka
# 向主题发布一些信息

启动消费者

1
2
3
4
kafka-console-consumer.sh --zookeeper localhost:2181 --topic mykafka --from-beginning
# --from-beginning 从头开始
# 无 --from-beginning 忽略以前的消息