本文主要是介绍5.5卡夫卡入门,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
进入官网后,
进行配置
server表示 卡夫卡临时产生的数据存放路径
表示日志存放位置
配置好以后,启动卡夫卡,
启动成功:
在目录下生成zookeeper
还有kafka-logs
一个副本,一个分区,主题的名字 test
以生产者的模式发送消息,调用生产者模式
出现一个小三角,输入:
再次打开cmd窗口,这是消费者,要读消息
依次读到消息:
在生产者 窗口不管写什么,都会出现在消费者的窗口,两个端口产生了通信。
这篇关于5.5卡夫卡入门的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!