Windows 下本地运行 Kafka_菜鸟日常的博客-程序员秘密

文章目录

介绍

本地运行 kafka，运行生产消费实例。
Kafka 是一个分布式发布-订阅消息系统。Zookeeper 是一个高性能分布式应用协调服务。
他们之间的关系参考

环境安装

1. 安装 Zookeeper

参考配置地址
注意 环境变量 配置，配置文件重命名
启动方式：Windows 平台直接点击 zkServer.cmd，Linux 平台 ./zkServer.sh start
Zookeeper 可视化（可选）：安装 zk ui，先用 maven 打包，再修改配置文件，再启动

#vim config.cfg
serverPort=9090     # zk ui 对外服务的端口
zkServer=localhost:2181 # zookeeper 的服务端口
sessionTimeout=300000

java -jar target/zkui-2.0-SNAPSHOT-jar-with-dependencies.jar &

2. 安装 Kafka

下载地址，下载二进制文件，即 Binary downloads
config/server.properties 配置，参考

listeners=PLAINTEXT://:9092
advertised.listeners=PLAINTEXT://192.168.2.104:9092  # 对应 kafka 运行的机器的 ip 地址
zookeeper.connect=localhost:2181 # 连接 zookeeper

运行调试

启动 Kafka，Windows 进入 C:\canal\kafka_2.11-2.0.1\bin\windows 目录下，新建窗口

kafka-server-start.bat ../../config/server.properties

新建窗口，新建 topic 为 testDemo 的 Producer，在 Consumer 窗口下可以看到相应的输出

kafka-console-producer.bat --broker-list localhost:9092 --topic testDemo
> 123

新建窗口，新建 Consumer，接收 topic 为 testDemo 的消息，bin\windows 目录下

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic testDemo

查看这个 kafka 服务下所有的 topic

kafka-topics.bat --list --zookeeper 127.0.0.1:2181

本地运行遇到的问题

consumer zookeeper is not a recognized option

办法：版本问题，使用 --bootstrap-server 代替 --zookeeper-server

本文链接：https://blog.csdn.net/u013151053/article/details/84331553

原作者删帖不实内容删帖广告或垃圾文章投诉

智能推荐

[ctf.show]命令执行29-54_"if(!preg_match(\"/vi|less|tail|head|od|sh|echo|to_huamanggg的博客-程序员秘密

web 29代码审计error_reporting(0);if(isset($_GET['c'])){ $c = $_GET['c']; if(!preg_match("/flag/i", $c)){ eval($c); } }else{ highlight_file(__FILE__);}涉及到一个函数preg_match()：这个preg_match 函数用于执行一个正则表达式匹配。看这次的判断是不能出现flag字样，后面的i意思

识别连笔字的软件_在线手写文字识别软件快速代抄_weixin_39883705的博客-程序员秘密

隶书教程隶书教程吴先生经过仔细排比研究，得出那样的科学论据来，作为学术上篆、隶的不同定名的分野，自然是很值得重视的。不过还有两个问题想要问，那就是∶一，篆书也不能够个个是象形字，一开始就有象形以外的许多字存在，因此，仅仅失掉“象形原意”似乎有些不够。我的意思是说隶的古文(“象形字”是一种字体的笼统名称，事实并非个个“象形”，例子甚多，不待列举)，不仅仅是象形而已。二，今天看到的从湖北云梦出土的秦简...

垂直居中多行文字_cunque0995的博客-程序员秘密

如果您只有一个单词或一行文本，那么有一种巧妙的方法可以使用CSS将其垂直居中放置在一个块中。您设置该文本的行高等于框的高度。效果很好，但是如果该文本需要换行，则会导致重大失败。 “语音气泡”是一个典型的示例，它表示我们可能希望文本在水平和垂直方向上居中并适应多行。使用CSS表有一个相当简单CSS技巧。结果如下：查看演示下载文件 HTML没什么花哨的。 “区域”只...

springboot-日志配置logback.xml文件_Mr丶小帆的博客-程序员秘密

springboot默认日志系统Spring Boot默认使用LogBack日志系统，如果要使用LogBack，原则上是需要添加dependency依赖：<groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-logging</artifactId>&...

python程序输出田字格_Python程序练习题5.1-输出更大的田字格。_weixin_39924307的博客-程序员秘密

原博文2019-09-25 16:05 −def drawsq(n): line=3*n+1 for i in range(1,line+1): if i%3 ==1: print(n*"+----",end="") print("+") else...01465相关推荐2019-12-22 15:50 −#### ★题目描述GYY面前有N堆果子，分...

【转载】HttpWebRequest的GetResponse或GetRequestStream偶尔超时 + 总结各种超时死掉的可能和相应的解决办法_kuangben2000的博客-程序员秘密

【转载】HttpWebRequest的GetResponse或GetRequestStream偶尔超时 + 总结各种超时死掉的可能和相应的解决办法https://www.cnblogs.com/summer_adai/archive/2013/04/26/3045253.html【转载】HttpWebRequest的GetResponse或GetRequestStream偶尔超时 + 总结各种超时死掉的可能和相应的解决办法【问题】用C#模拟网页登陆，其中去请求几个页面，会发起对应的h.