2016-09-07 85 views
0

當我嘗試將我的Arduino uno與PubSubClient庫(如客戶端)連接到我的Apache Kafka服務器時遇到問題。與arduino客戶端發出apache kafka連接

當嘗試建立連接,在服務器上我有這樣的:

[2016年9月7日16:30:59093]從/192.168.1.104 WARN意外的錯誤;關閉連接(org.apache.kafka.common.network .Selector) org.apache.kafka.common.network.InvalidReceiveException:無效接收(大小= 104857600比大270204932) 在org.apache.kafka.common .network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:91) at org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:71) at org.apache.kafka.common.network.KafkaChannel.receive (KafkaChannel.java:154) at org.apache.kafka.common.network.KafkaChannel.read(KafkaChannel.java:135) at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:323 ) at org.apache.kafka.common.network.Selector.poll(Selector.java:283) at kafka.network.Processor.poll(SocketServer.scala:472) at kafka.network.Processor.run(SocketServer.scala:412) at java.lang.Thread.run(Thread.java:745)

回答

-1

看起來有經紀人間的溝通,因爲經紀人得到的請求比默認允許的大小10MB多 。請重新安裝kafka集羣,看看它是否有幫助。