遇到一个问题，使用Python kafka客户端和kafka命令行都无法消费数据，但是在kafka命令行后面添加--partition 0后就可以消费数据。

bin/kafka-console-consumer.sh --topic eems_td_meter --from-beginning     --bootstrap-server 172.18.185.123:,172.18.185.124:  # 不能消费数据

bin/kafka-console-consumer.sh --topic eems_td_meter --from-beginning     --bootstrap-server 172.18.185.123:,172.18.185.124: --partition   # 添加partiton参数后可以消费数据

原因在与offsets.topic.replication.factor的值在配置文件中大于了节点个数（两个节点，却将这个值设置为了３），

设定更大的复制因子可以确保更高的可用性。但是如果复制因子大于集群节点数，内部主题自动创建将会失败,直到集群大小符合这个复制因子的要求 (范围: 1 - 100)。

在修改

offsets.topic.replication.factor=

之后，不用再指定分区信息就可以消费数据。

ref: https://stackoverflow.com/questions/34844209/consumer-not-receiving-messages-kafka-console-new-consumer-api-kafka-0-9

最新文章

  1. C语言第三次作业
  2. Swift---TextView用法
  3. 《DSP using MATLAB》示例Example4.4
  4. Section 1.4 Mother's Milk
  5. Beautiful Soup第三方爬虫插件
  6. Android 基于Socket的聊天应用(二)
  7. JS认证Exchange
  8. Backbone
  9. 【Linux.Python】Python进程后台启动
  10. first move advantage_百度搜索
  11. Long，String类型的两个值进行比较，注意点！！！
  12. Android Camera 调用流程总结
  13. mysql 分库分表 ~ 方案选择浅谈
  14. python set的函数
  15. UltraISO 9.7.1.3519注册码
  16. Python Microsoft Visual C++ 10.0 is required (Unable to find vcvarsall.bat)
  17. BZOJ.1024.[SCOI2009]生日快乐(记忆化搜索)
  18. javascript将算法复杂度从O(n^2)做到O(n)
  19. python简单计时器实现
  20. 【Floyd矩阵乘法】BZOJ1706- [usaco2007 Nov]relays 奶牛接力跑

热门文章

  1. [转][C#]单例模式之懒加载
  2. 廖雪峰Java6 IO编程-2input和output-5操作zip
  3. android 根据滑动隐藏或显示导航 类似手机QQ好友个人信息
  4. linux下新建（mkdir）、删除（rmdir）文件夹
  5. Version 版本定义规则
  6. CS229 2.深入梯度下降(Gradient Descent)算法
  7. Centos7使用pxe安装KVM虚拟机
  8. Java连接postgreSQL数据库，找不到表。
  9. python爬虫之登录
  10. git push declined due to email privacy restrictions 解决方法