You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@storm.apache.org by "qianmoQ (JIRA)" <ji...@apache.org> on 2019/06/01 03:30:01 UTC
[jira] [Commented] (STORM-3398) Closing socket for xxx because of
error (kafka.network.Processor) kafka.network.InvalidRequestException
[ https://issues.apache.org/jira/browse/STORM-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16853580#comment-16853580 ]
qianmoQ commented on STORM-3398:
--------------------------------
replace storm-kafka-monitor to your kafka version, solve the problem!!!
egg:
your kafka version: 0.10.0.0
replace storm-kafka-monitor version to 1.1.0
rm source toollib/storm-kafka-monitor-*.jar or rename this
> Closing socket for xxx because of error (kafka.network.Processor) kafka.network.InvalidRequestException
> -------------------------------------------------------------------------------------------------------
>
> Key: STORM-3398
> URL: https://issues.apache.org/jira/browse/STORM-3398
> Project: Apache Storm
> Issue Type: Bug
> Components: storm-kafka-client
> Affects Versions: 1.1.0, 1.2.2
> Environment: Strom 1.2.2
> storm-kafka-client 1.1.0
> kafka cdh0.10.0.0
> Reporter: qianmoQ
> Priority: Major
>
> deploy a topology on storm cluster, storm start a *org.apache.storm.kafka.monitor.KafkaOffsetLagUtil* process, this process error:
> {code:java}
> [2019-05-31 11:24:54,425] ERROR Closing socket for xxxx:9092-xxxxx:17547 because of error (kafka.network.Processor)
> kafka.network.InvalidRequestException: Error getting request for apiKey: 3 and apiVersion: 2
> at kafka.network.RequestChannel$Request.liftedTree2$1(RequestChannel.scala:95)
> at kafka.network.RequestChannel$Request.<init>(RequestChannel.scala:87)
> at kafka.network.Processor$$anonfun$processCompletedReceives$1.apply(SocketServer.scala:488)
> at kafka.network.Processor$$anonfun$processCompletedReceives$1.apply(SocketServer.scala:483)
> at scala.collection.Iterator$class.foreach(Iterator.scala:893)
> at scala.collection.AbstractIterator.foreach(Iterator.scala:1336)
> at scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
> at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
> at kafka.network.Processor.processCompletedReceives(SocketServer.scala:483)
> at kafka.network.Processor.run(SocketServer.scala:413)
> at java.lang.Thread.run(Thread.java:745)
> Caused by: java.lang.IllegalArgumentException: Invalid version for API key 3: 2
> at org.apache.kafka.common.protocol.ProtoUtils.schemaFor(ProtoUtils.java:31)
> at org.apache.kafka.common.protocol.ProtoUtils.requestSchema(ProtoUtils.java:44)
> at org.apache.kafka.common.protocol.ProtoUtils.parseRequest(ProtoUtils.java:60)
> at org.apache.kafka.common.requests.MetadataRequest.parse(MetadataRequest.java:96)
> at org.apache.kafka.common.requests.AbstractRequest.getRequest(AbstractRequest.java:48)
> at kafka.network.RequestChannel$Request.liftedTree2$1(RequestChannel.scala:92)
> {code}
> Too many kafka sockets lead to delayed consumption and production of kafka services
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)