kafak基本操作

Posted 2020-10-04 疯码牛

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了kafak基本操作相关的知识，希望对你有一定的参考价值。

创建topic

bin/kafka-topics.sh --create --zookeeper 192.168.1.81:2181 --replication-factor 3 -partitions 10 --topic RecordPreprocessingTest1

##控制台发送消息

bin/kafka-console-producer.sh --broker-list 192.168.1.81:9092 --topic RecordPreprocessingTest1

bin/kafka-console-consumer.sh --zookeeper 192.168.1.83:2181 --from-beginning --topic RecordPreprocessingTest1

以上是关于kafak基本操作的主要内容，如果未能解决你的问题，请参考以下文章