Ubuntu18.04搭建kafka集群
小编:动力软件园 时间:2019-05-20 19:33:30
下载地址:kafka
解压,修改文件夹名称
创建日志目录
进入config目录,修改server.properties
修改一下日志目录
先启动zeekeeper,然后启动kafka
后面的是刚刚修改的配置文件的路径
这里报了个错误,kafka-run-class.sh找不到java
这里要重新执行一下
source /etc/profile
然后就行了
创建Topic,打开另一个tab
列出所有Topic
启动生产者Producer并发送消息
启动消费者Consumer接受消息
使用下面的命令就可以了。
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
停止kafka
./kafka-server-stop.sh
kafka一些常用命令
1)、启动kafka命令:
cd /opt/kafka_2.10-0.10.1.1/bin;
./kafka-server-start.sh /opt/kafka_2.10-0.10.1.1/config/server.properties
(2)、停止kafka命令:
./kafka-server-stop.sh
(3)、创建Topic:(创建一个名为test的topic,只有一个副本,一个分区。)
./kafka-topics.sh --create --zookeeper 127.0.0.1:2181 --replication-factor 1 --partitions 1 --topic test
(4)、列出所有Topic:
./kafka-topics.sh -list -zookeeper 127.0.0.1:2181
(5)、启动Producer并发送消息:
./kafka-console-producer.sh --broker-list localhost:9092 --topic test
(输入相应的消息,eg:hello kafka;按Ctrl+C结束)
(6)、启动Consumer并接收消息:
./kafka-console-consumer.sh --zookeeper 127.0.0.1:2181 --topic test --from-beginning