kafka从创建到消费之基础操作

一、创建

./bin/kafka-topics.sh --create --zookeeper 192.168.1.222:2181,192.168.1.223:2181,192.168.1.224:2181 --replication-factor 1 --partitions 1 --topic test1

Created topic "test1".

二、查看

[root@node1 kafka]# ./bin/kafka-topics.sh --list --zookeeper 192.168.1.222:2181,192.168.1.223:2181,192.168.1.224:2181

__consumer_offsets

filebeat-logstash

mydemo1

test1

三、生产

[root@node1 kafka]# ./bin/kafka-console-producer.sh --broker-list 192.168.1.222:9092,192.168.1.223:9092,192.168.1.224:9092 --topic test1

>bohaizhegnjuan-> logstash-> 192.168.1.222

>

四、消费

224:9092 --topic test1

[root@node1 kafka]# ./bin/kafka-console-consumer.sh --bootstrap-server  192.168.1.222:9092,192.168.1.223:9092,192.168.1.224:9092 --topic test1 --from-beginning

bohaizhegnjuan-> logstash-> 192.168.1.222