Kafka命令及相关参数解释
由于kafka是去中心化的架构，，所以需要在每台节点上启动kafka，且依赖于zookeeper，需要先启动zookeeper
启动kafka:
kafka-server-start.sh -daemon /opt/modules/kafka_2.12-2.4.0/config/server.properties
-daemon是后台启动的意思
创建一个新的topic：
kafka-topics.sh --create --zookeeper hadoop01:2181,hadoop02:2181,hadoop03:2181 --replication-factor 3 --partitions 3 --topic topicname
–replication-factor 副本的数量
–partitions 分区的数量
查看所有的Topic：
kafka-topics.sh --list --zookeeper hadoop01:2181,hadoop02:2181,hadoop03:2181
启动一个控制台生产者：
kafka-console-producer.sh --topic topicname --broker-list hadoop01:9092,hadoop02:9092,hadoop03:9092
–broker-list broker的列表，端口号是默认的，如果你修改了，需要指定为你修改过的端口
启动控制台消费者：
kafka-console-consumer.sh --bootstrap-server hadoop01:9092,hadoop02:9092,hadoop03:9092 --topic topicname
指定消费的topic的名字
查看一个topic的描述:
kafka-topics.sh --describe --zookeeper hadoop01:2181,hadoop02:2181,hadoop03:2181 --topic topicname
写的不好还请在评论区指出，感谢您的阅读。
|