kafka单机安装

Posted 2021-03-07 breakingbrad

引用：https://www.cnblogs.com/adolfmc/p/7345333.html

创建一个消息队列：

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

　　创建队列的时候，replication-factor只能是1个，因为是单节点，而partitions分区可以是1个或者2个都可以，测试环境建议是1个即可

　　然后，创建一个消费者：

bin/kafka-console-consumer.sh --zookeeper localhost:2181/kafka --topic test

　　此时，命令行会进入运行状态，界面就卡住不动了，然后再新建一个窗口，进入kafka目录，继续创建一个生产者：

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

　　同样这个时候命令行进入运行状态，我们输入一个字符串：Hello Kafka!

　　

　　此时打开刚才创建消费者的窗口，会看到刚才的输入消息被消费了

　　

　　到现在，Kafka单机消息队列基本的配置和运行都是正常的，单机环境配置基本上就是这些

 

分类: bigdata