[ https://issues.apache.org/jira/browse/KAFKA-10450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188235#comment-17188235 ]
Luke Chen commented on KAFKA-10450: ----------------------------------- I think this behavior is expected. The *address already in use* error did display, in *kafka-server-start.sh*. The console-producer.sh (client) is expected that kafka server is up and just send messages to kafka server directly. It will throw exception when the server is not responding, but not the server working differently (in your case, it's the unexpected response from sonarqube H2 DB). {code:java} $ bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092 ... [2020-09-01 15:47:58,404] ERROR [KafkaServer id=0] Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer) org.apache.kafka.common.KafkaException: Socket server failed to bind to 0.0.0.0:9092: Address already in use. at kafka.network.Acceptor.openServerSocket(SocketServer.scala:673) at kafka.network.Acceptor.<init>(SocketServer.scala:541) at kafka.network.SocketServer.createAcceptor(SocketServer.scala:278) at kafka.network.SocketServer.$anonfun$createDataPlaneAcceptorsAndProcessors$1(SocketServer.scala:250) at kafka.network.SocketServer.$anonfun$createDataPlaneAcceptorsAndProcessors$1$adapted(SocketServer.scala:248) at scala.collection.IterableOnceOps.foreach(IterableOnce.scala:553) at scala.collection.IterableOnceOps.foreach$(IterableOnce.scala:551) at scala.collection.AbstractIterable.foreach(Iterable.scala:920) at kafka.network.SocketServer.createDataPlaneAcceptorsAndProcessors(SocketServer.scala:248) at kafka.network.SocketServer.startup(SocketServer.scala:122) at kafka.server.KafkaServer.startup(KafkaServer.scala:299) at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:44) at kafka.Kafka$.main(Kafka.scala:82) at kafka.Kafka.main(Kafka.scala) Caused by: java.net.BindException: Address already in use at sun.nio.ch.Net.bind0(Native Method) at sun.nio.ch.Net.bind(Net.java:433) at sun.nio.ch.Net.bind(Net.java:425) at sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:223) at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:74) at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:67) at kafka.network.Acceptor.openServerSocket(SocketServer.scala:669) ... 13 more {code} > console-producer throws Uncaught error in kafka producer I/O thread: > (org.apache.kafka.clients.producer.internals.Sender) > java.lang.IllegalStateException: There are no in-flight requests for node -1 > ------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- > > Key: KAFKA-10450 > URL: https://issues.apache.org/jira/browse/KAFKA-10450 > Project: Kafka > Issue Type: Bug > Components: producer > Affects Versions: 2.6.0 > Environment: Kafka Version 2.6.0 > MacOS Version - macOS Catalina 10.15.6 (19G2021) > java version "11.0.8" 2020-07-14 LTS > Java(TM) SE Runtime Environment 18.9 (build 11.0.8+10-LTS) > Java HotSpot(TM) 64-Bit Server VM 18.9 (build 11.0.8+10-LTS, mixed mode) > Reporter: Jigar Naik > Priority: Minor > > Kafka-console-producer.sh gives below error on Mac > ERROR [Producer clientId=console-producer] Uncaught error in kafka producer > I/O thread: (org.apache.kafka.clients.producer.internals.Sender) > java.lang.IllegalStateException: There are no in-flight requests for node -1 > *Steps to re-produce the issue.* > Download Kafka from > [kafka_2.13-2.6.0.tgz|https://www.apache.org/dyn/closer.cgi?path=/kafka/2.6.0/kafka_2.13-2.6.0.tgz] > > Change data and log directory (Optional) > Create Topic Using below command > > {code:java} > ./kafka-topics.sh \ > --create \ > --zookeeper localhost:2181 \ > --replication-factor 1 \ > --partitions 1 \ > --topic my-topic{code} > > Start Kafka console producer using below command > > {code:java} > ./kafka-console-consumer.sh \ > --topic my-topic \ > --from-beginning \ > --bootstrap-server localhost:9092{code} > > Gives below output > > {code:java} > ./kafka-console-producer.sh \ > --topic my-topic \ > --bootstrap-server 127.0.0.1:9092 > >[2020-09-01 00:24:18,177] ERROR [Producer clientId=console-producer] > >Uncaught error in kafka producer I/O thread: > >(org.apache.kafka.clients.producer.internals.Sender) > java.nio.BufferUnderflowException > at java.base/java.nio.Buffer.nextGetIndex(Buffer.java:650) > at java.base/java.nio.HeapByteBuffer.getInt(HeapByteBuffer.java:391) > at > org.apache.kafka.common.protocol.ByteBufferAccessor.readInt(ByteBufferAccessor.java:43) > at > org.apache.kafka.common.message.ResponseHeaderData.read(ResponseHeaderData.java:102) > at > org.apache.kafka.common.message.ResponseHeaderData.<init>(ResponseHeaderData.java:70) > at > org.apache.kafka.common.requests.ResponseHeader.parse(ResponseHeader.java:66) > at > org.apache.kafka.clients.NetworkClient.parseStructMaybeUpdateThrottleTimeMetrics(NetworkClient.java:717) > at > org.apache.kafka.clients.NetworkClient.handleCompletedReceives(NetworkClient.java:834) > at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:553) > at org.apache.kafka.clients.producer.internals.Sender.runOnce(Sender.java:325) > at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:240) > at java.base/java.lang.Thread.run(Thread.java:834) > [2020-09-01 00:24:18,179] ERROR [Producer clientId=console-producer] Uncaught > error in kafka producer I/O thread: > (org.apache.kafka.clients.producer.internals.Sender) > java.lang.IllegalStateException: There are no in-flight requests for node -1 > at > org.apache.kafka.clients.InFlightRequests.requestQueue(InFlightRequests.java:62) > at > org.apache.kafka.clients.InFlightRequests.completeNext(InFlightRequests.java:70) > at > org.apache.kafka.clients.NetworkClient.handleCompletedReceives(NetworkClient.java:833) > at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:553) > at org.apache.kafka.clients.producer.internals.Sender.runOnce(Sender.java:325) > at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:240) > at java.base/java.lang.Thread.run(Thread.java:834) > [2020-09-01 00:24:18,682] WARN [Producer clientId=console-producer] Bootstrap > broker 127.0.0.1:9092 (id: -1 rack: null) disconnected > (org.apache.kafka.clients.NetworkClient) > {code} > > > The same steps works fine with Kafka version 2.0.0 on Mac. > The same steps works fine with Kafka version 2.6.0 on Windows. > > -- This message was sent by Atlassian Jira (v8.3.4#803005)