kafka使用笔记

启动生产者和消费者的时候报错：

1）查看Kafka的配置文件，cat config/server.properties

zookeeper.connect=localhost:2181

连接的zookeeper的为localhost，所以需要用localhost启动生产和消费进程

vi config/server.properties，将listeners改掉

listeners=PLAINTEXT://localhost:9092

启动zookeeper：bin/zookeeper-server-start.sh config/zookeeper.properties

启动Kafka：bin/kafka-server-start.sh config/server.properties

创建Kafka主题：

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1   
--partitions 1 --topic Hello-Kafka

我们刚刚创建了一个名为 Hello-Kafka 的主题，其中包含一个分区和一个副本因子。

启动生产者： bin/kafka-console-producer.sh --broker-list localhost:9092 --topic Hello-Kafka

启动消费者：bin/kafka-console-consumer.sh --zookeeper localhost:2181 —topic Hello-Kafka --from-beginning --whitelist Hello-Kafka

https://www.w3cschool.cn/apache_kafka/apache_kafka_basic_operations.html

kafka常用命令：

检测2181与9092端口

netstat -tunlp|egrep "(2181|9092)"
tcp        0      0 :::2181                     :::*                        LISTEN      19787/java          
tcp        0      0 :::9092                     :::*                        LISTEN      28094/java

说明：

Kafka的进程ID为28094，占用端口为9092

猜你喜欢