kafka 启动报错

虚拟机上的 kafka 被强制断电之后,重新启动的时候报错 [2019-01-03 15:57:46,279] INFO Creating /brokers/ids/1 (is it secure? false) (kafka.utils.ZKCheckedEphemeral) [2019-01-03 15:57:46,294] INFO Result of znode creation is: NODEEXISTS (kafka.utils.ZKCheckedEphemeral) [2019-01-03 15:57:46,295] F……

阅读全文

kafka + spark streaming(1)

之前写过一个 kafka + spark streaming 的测试用例,但是当时没有记录下来,这部分的东西还是很重要的,需要找时间回头补上 看到这里有一个教程, http://colobu.com/2015/01/05/k… 写的挺不错 ——————- 2018-11-12 21:26:25 追加 终于来补上这个坑,一晃都快一年过去了,真的……

阅读全文

kafka 发送消息卡顿 60s

今天遇到这么一个问题, http://stackoverflow.com/quest… 跟这位哥们的问题一模一样,Kafka 在 producer 调用 send 发送数据的时候卡住一分钟,精确的一分钟,然后函数返回,没有抛出异常 我比原题中的案例还肯定这一点的原因是我在 send 的前后分别打了日志 在这里, http://blog.chinaunix.net/xmlr… 看到……

阅读全文