第一步 创建Zookeeper

下载完成后 修改 Zookeeper中的 zoo.cfg

修改 dataDir 、dataLogDir

集群模式

server.1=ServerIP:2888:3888

第二步  创建 kafka

检查 server.properties 是否正确

配置端口

listeners=PLAINTEXT://:9092

advertised.listeners=PLAINTEXT://本机IP:9092

第三步 启动 Zookeeper 和kafka

建立 bat  启动Zookeeper

cd F:\DB_Broker\zookeeper-3.4.\bin
zkServer.cmd
pause;

建立 bat 启动 kafka

cd F:\DB_Broker\kafka_2.-2.4.
.\bin\windows\kafka-server-start.bat .\config\server.properties
pause;

第四步  测试 kafka 是否正常

创建 topic

.\bin\windows\kafka-topics.bat --create --zookeeper localhost: --replication-factor  --partitions  --topic test

创建  生产者

.\bin\windows\kafka-console-producer.bat --broker-list localhost: --topic test   

(输入 任意信息 )

创建 消费者

.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost: --topic test --from-beginning  

(是否接受正常)

辅助类工具

查看 Zookeeper 信息   --------------  ZooInspector

查看kafka     -----------------    kafka tool 2

最新文章

  1. 找回Reshaprer的Alt+Enter快捷键的方法
  2. struts2加入自定义的actionValidatorManager实现类
  3. [Stephen]Android的adb无法启动
  4. CI 笔记3 (easyui 和 js 排错)
  5. 栈和队列的面试题Java实现
  6. C#委托 Lamda表达式
  7. 关于运行robotium提示连接不上jar问题
  8. M、V、C
  9. 【java学习】Servlet简单的表单程序(一)
  10. Excel公式-求最低价网站名字
  11. 阿里聚安全移动安全专家分享:APP渠道推广作弊攻防那些事儿
  12. HTTP错误代码大全
  13. 解决由于VNC日志导致服务器磁盘100%
  14. error_reporting
  15. Hama安装及示例运行
  16. 第一节: 结合EF的本地缓存属性来介绍【EF增删改操作】的几种形式
  17. js如何获得局部变量的值
  18. 犯罪心理第一季/全集Criminal Minds迅雷下载
  19. 【比特币】SPV是如何工作的
  20. Excel只能输入不许修改

热门文章

  1. git 合并远程分支
  2. js在页面中添加一个元素 —— 添加弹幕
  3. 定位网页元素、透明度、z-index、包裹性和破坏性
  4. SpringCloud常用注解有哪些?
  5. python线程池--threadpool
  6. Lambda表达式动态组装查询条件
  7. Linux 命令 watch 监测命令的运行结果
  8. Linux系统管理和调优(内存、CPU、磁盘IO、网络)
  9. 小记---------Hadoop的MapReduce基础知识
  10. 记一次程序从x86_64linux平台移植到armv7平台