kafka2.5.0基本命令
Posted zhuwenjoyce
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了kafka2.5.0基本命令相关的知识，希望对你有一定的参考价值。
1）启动zookeeper
演示用的话，直接启动kafka自带的zookeeper即可：
cd kafkaDirectory/kafka_2.12-2.5.0 bin/zookeeper-server-start.sh config/zookeeper.properties
生产上建议连接到zookeeper集群，需更改配置文件 config/server.properties 里更改zookeeper配置zookeeper.connect=localhost:2181
2) 启动kafka server
cd kafkaDirectory/kafka_2.12-2.5.0 bin/kafka-server-start.sh config/server.properties
3) 主题topic
创建topic : test
bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test
列出topic：
bin/kafka-topics.sh --list --bootstrap-server localhost:9092
往test Topic里发送数据：
bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic test
从test Topic里面从头开始消费数据：
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
end.
以上是关于kafka2.5.0基本命令的主要内容，如果未能解决你的问题，请参考以下文章
kafka2.5.0硬件集群架构图Topic主题与Partitions分区架构图