使用storm spout消息时发生java.nio.channels.ClosedChannelException
共有1个答案
看来暴风工人想读Kafka经纪人的文章时你暂停了。也许他们之间的联系是片状的或缓慢的？
话虽如此，堆栈跟踪似乎表示消费者重新连接了，所以如果这种情况很少发生，那么您可能只是在工作者和Kafka之间的连接中遇到了一个小问题。
如果这种情况经常发生，并且您确信连接是稳定的，我会尝试在Kafka的邮件列表上询问一下，网址是https://Kafka.apache.org/contact。如果您发布了您的问题以及您正在使用的Kafka版本，他们可能会告诉您是否存在可能导致使用者的套接字超时的问题。
-
我在这里得到的例外情况是： 通过字段“jms template”表示的不满足的依赖关系；嵌套异常为org.springframework.beans.factory.beanCreationException：创建类路径资源[com/investmentbank/equityfeedsprocessingremission/config/config.class]中定义的名为“JMS Templa
-
我在discord.py做了一个机器人，希望我的机器人在网络钩子在特定频道发送消息时定位一个角色。有办法这么做吗？现在所有我有的是通道ID和我很确定这是一个客户端事件
-
我想用grafana显示指标（只是一个简单的每秒/分钟请求数计数器）。我使用石墨收集指标。 当我使用java向graphite报告请求时： 问题是，一切都毫无例外地运行，但是Graphite服务器没有得到任何指标。知道她怎么了吗？ 此外，该指标的名称（mymetrics.requests.successful）没有出现在指标系列的列表中。 非常感谢提前！
-
我正在寻找一种方式发布芹菜消息到SNS主题，以订阅多个队列。 我之所以要这样做，是因为我正在尝试使用Celery实现多个接收器模式
-
我正试图弄清楚如何使用Firebase向Android推送通知，并使用遗留HTTP使其正常工作(https://fcm.googleapis.com/fcm/send)但文件建议使用较新的endpoint(https://fcm.googleapis.com/v1/projects/myproject-b5ae1/messages:send).我似乎无法让它工作，因为我一直得到这样的回应： 使用h
-
在阅读了大量的Kafka合流式聊天的文章后，我想尝试一下如何实现一个普通的聊天系统。但是我在做一些结构设计的时候遇到了一些问题。当使用mysql作为数据的数据库时，我可以给每个有意义的消息赋予，比如user表中的user_id，消息表中的message_id。模型表中有了id后，可以方便地进行客户端和服务器端的通信。但是在Kafka流中，我如何在Ktable中给每个有意义的模型一个唯一的id？还是