使用flume将文件数据解析发送到kafka上，然后使用storm（storm运行自己写的java程序，程序中使用kafka 的consumer）读取kafka中的数据，使用zookeeper管理集群，有3个节点，报错如下：
从报错上看是其中的一个主机的kafka与zookeeper的通信有问题？不过这只是我的猜测，大牛们遇到过类似的问题吗？或者说 有什么解决问题的思路吗？
补充，就这一个主机有问题，却导致了storm无法正常运行，无法读取任何数据。
无法读取集群中kafka中的数据
- 写回答
- 好问题 0 提建议
- 追加酬金
- 关注问题
分享- 邀请回答
-
1条回答
- 2022-07-13 20:33回答 3 已采纳 restclient异常，先看看taskmanager和jobmanager是否正常，然后你可以在jobmanager的节点上访问webUI查看job状态，又或者直接查看宿主机上的日志排查问题
- 2022-02-16 19:32回答 4 已采纳 重新开一个topic，然后先启动consumer，再启动producer，再发消息，你这个可能是consumer已经在broker里有了自己的offset，就会读不到之前producer发送到brok
- 2022-01-28 09:47回答 1 已采纳 那最后写入到库了吗，如果写不进去，上游kafka肯定会延迟越来越大的，可以在sink里多打印下错误，或者设置写入超时时间，问题应该在写入
- 2023-03-12 02:10Storm集成Kafka 一、整合说明 二、写入数据到Kafka 三、从Kafka中读取数据 从Kafka中读取数据 Storm从Kafka集群读取数据处理
- 2021-06-17 17:19回答 10 已采纳 https://blog.csdn.net/qq_40407889/article/details/118028472 java的kafka操作的简单demo
- 2021-09-22 19:23回答 1 已采纳 你这是。。。 自问自答？
- 2022-07-21 16:59回答 1 已采纳 内部是9092端口，外部用31082端口
- 2023-03-12 11:21今天接上文，来实现一个Storm数据流处理综合案例的第二部分，Storm集群向Kafka集群源源不断读取数据，通过MyBatis写入到MySQL数据库，并部署为远程模式 准备工作 参考上文准备工作 代码编写 思路：Storm集群从...
- 2023-01-06 12:17回答 1 已采纳 是的。如果有副本的话，副本分区也有这个消息。
- 2021-07-05 16:53回答 1 已采纳 value的值为[B@1e1e585b这个明显是序列化后的Bytes字节类型嘛你反序列化成string就ok了
- 2021-04-20 10:49回答 3 已采纳 https://gewu.pcwanli.com/front/article/10619.html
- 2024-01-04 01:42flink读取kafka数据，按照业务逻辑计算完之后以数据流的方式快速导入到redis集群，并实现了将计算结果以流的方式快速导入MySQL库中。
- 2021-07-22 08:54回答 4 已采纳 用@Scheduledhttps://blog.csdn.net/limingcai168/article/details/103394041
- 2022-08-15 11:29努力搬砖的猪头的博客 【Kafka】从kafka中读取最新数据
- 2022-10-24 11:28潮浪之巅的博客 Apache Flume 是一个分布式、高可靠、高可用的用来收集、聚合、转移不同来源的大量日志数据到中央数据仓库的工具。
- 没有解决我的问题, 去提问
悬赏问题
- ¥20 ML307A在使用AT命令连接EMQX平台的MQTT时被拒绝
- ¥20 腾讯企业邮箱邮件可以恢复么
- ¥15 有人知道怎么将自己的迁移策略布到edgecloudsim上使用吗？
- ¥15 错误 LNK2001 无法解析的外部符号
- ¥50 安装pyaudiokits失败
- ¥15 计组这些题应该咋做呀
- ¥60 更换迈创SOL6M4AE卡的时候，驱动要重新装才能使用，怎么解决？
- ¥15 让node服务器有自动加载文件的功能
- ¥15 jmeter脚本回放有的是对的有的是错的
- ¥15 r语言蛋白组学相关问题