kafka学习

1、安装kafka

　　安装包的修改配置文件server.properties

broker.id=0
listeners=PLAINTEXT://172.19.0.5:9092
zookeeper.connect=172.19.0.4:2181,172.19.0.5:2181,172.19.0.6:2181/kafka

　　启动kafka

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

2、创建topic

　　./kafka-topics.sh --zookeeper 172.19.0.4:2181,172.19.0.5:2181,172.19.0.6:2181/kafka --create --topic yhqtopic --partitions 1 --replication-factor 1

3、生产者与消费者

　　./kafka-console-producer.sh --broker-list 172.19.0.5:9092 --topic yhqtopic

　　./kafka-console-consumer.sh --bootstrap-server 172.19.0.5:9092 --topic yhqtopic

4、java客户端

 

标签：topic,0.5,kafka,学习,2181,172.19,server
来源： https://www.cnblogs.com/yaohuiqin/p/13124840.html