启动kafka命令

[root@localhost kafka_2.12-3.0.0]# bin/kafka-server-start.sh -daemon config/server.properties 

[root@localhost kafka_2.12-3.0.0]# ps -ef | grep kafka

查看当前服务器中的所有topic

[root@localhost kafka_2.12-3.0.0]# bin/kafka-topics.sh --bootstrap-server 172.27.1.191:9092 --list

创建topic

--topic 定义 topic名

--replication-factor 定义副本数 定义副本数

--partitions 定义分区数 定义分区数 定

 

sudo systemctl start kafka

sudo systemctl status kafka

sudo systemctl stop kafka

 

bin/kafka-topics.sh --create --zookeeper 172.27.1.191:2181 --replication-factor 1 --partitions 1 --topic testTopic

.\bin\windows\kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test

 

bin/kafka-topics.sh --list --zookeeper 172.27.1.98:2181

生产者发送消息

bin/kafka-console-producer.sh --broker-list 172.27.1.191:9092 --topic testTopic

消费者接收消息

bin/kafka-console-consumer.sh --bootstrap-server 172.27.1.191:9092 --topic testTopic --from-beginning