解压kafka的安装包,在bin目录下自带了一些客户端的命令行工具。有些操作是指定zookeeper的ip地址,有些操作则是连多个broker的ip地址。

1. 创建topic和查询topic

实际上发送消息之前是可以不用先手动创建topic的,topic会自动创建,但是用的是默认的配置,但是如果想设定topic的属性,则需要事先创建了,或者自动创建后及时修改属性。

#--replication-factor 创建的副本数,这个使用来备份的.副本数不能大于broker数
#--partitions 1 创建的分区数.根据实际情况创建
#--topic 创建的topic名称
./kafka-topics.sh --create --zookeeper 10.100.99.41:32181 --replication-factor 1 --partitions 1 --topic milo

列举出所有的topic:

./kafka-topics.sh --list --zookeeper 10.100.99.41:32181
# 显示topic详情
./kafka-topics.sh --describe --zookeeper  10.100.99.41:32181

2. 发送和接收消息

先开一个窗口接收消息,这里只能指定broker ip列表,多个用逗号隔开,不能指定zk了:

./kafka-console-consumer.sh --bootstrap-server 10.100.99.41:39092  --topic milo --from-beginning # 可以--group 指定消费者分组id

# --from-beginning 指定从头获取消息(最老的消息先获取),否则获取最新的消息

然后再开一个窗口发送消息:

./kafka-console-producer.sh --broker-list 10.100.99.41:39092 --topic milo   #回车,然后输入内容,每行是一条消息,空行也算一条
>hello world
文档更新时间: 2019-10-25 16:34   作者:nick