kafka单机安装
引用: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
相关推荐
huangwei00 2020-10-14
shenzhenzsw 2020-10-09
guicaizhou 2020-09-30
wangying 2020-06-28
猫咪的一生 2020-06-26
sweetgirl0 2020-06-25
猫咪的一生 2020-06-16
meilongwhpu 2020-06-08
东哥笔记 2020-06-05
sweetgirl0 2020-06-04
Kafka 2020-09-18
yanghuashuiyue 2020-11-14
liuxingen 2020-11-13
wangying 2020-11-13
王谦 2020-11-03
jiaomrswang 2020-09-23
jyj0 2020-09-21
guicaizhou 2020-09-15
hannuotayouxi 2020-08-20