Ubuntu18.04搭建kafka集群

下载地址：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