我是apache和kafka的新手,我试着通过OpenClassroom.The原理提供的课程来学习这些概念,通过python程序将消息发送到kafka服务器,并通过storm拓扑的主类中定义的kafka喷口检索消息。问题是我不明白螺栓是如何检索消息的。据我所知,这是在ParsingBolt类中使用以下代码行完成的:JSONObject obj = (JSONObject)jsonParser.parse(input.getStringByField("value"));。唯一的问题是,我不明白我们如何知道消息包含在value字段中。下面可以找到main类和parsing bo
我使用的是卡夫卡风暴,卡夫卡发送/发射json字符串到风暴,在风暴中,我想根据json中的键/字段将负载分配给几个工人。怎么做?在我的例子中,它是json字符串中的物流字段。
例如,我有这样的json:
{groupid: 1234, userid: 145, comments:"I want to distribute all this group 1234 to one worker", size:50,type:"group json"}
{groupid: 1235, userid: 134, comments:"I want to distr
我得到的异常风暴拓扑。
java.lang.NoSuchMethodError: org.apache.kafka.common.network.NetworkSend.<init>(Ljava/lang/String;[Ljava/nio/ByteBuffer;)V
at kafka.network.RequestOrResponseSend.<init>(RequestOrResponseSend.scala:41) ~[stormjar.jar:?]
at kafka.network.RequestOrResponseSend.<init&g
我写了一个ssh来执行几个与apache风暴相关的ssh远程组件。当我执行脚本时,它说:
ssh: connect to host XXX.XXX.XXX.XXX port 22: No route to host
ssh: connect to host XXX.XXX.XXX.XXX port 22: No route to host
ssh: connect to host XXX.XXX.XXX.XXX port 22: No route to host
ssh: connect to host XXX.XXX.XXX.XXX port 22: Connection refused
如