[
https://issues.apache.org/jira/browse/KAFKA-5079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar resolved KAFKA-5079.
------------------------------
Resolution: Fixed
ProducerBounceTest is removed as part old consumer changes.
> ProducerBounceTest fails occasionally with a SocketTimeoutException
> -------------------------------------------------------------------
>
> Key: KAFKA-5079
> URL: https://issues.apache.org/jira/browse/KAFKA-5079
> Project: Kafka
> Issue Type: Bug
> Reporter: Apurva Mehta
> Priority: Major
>
> {noformat}
> java.net.SocketTimeoutException
> at
> sun.nio.ch.SocketAdaptor$SocketInputStream.read(SocketAdaptor.java:229)
> at sun.nio.ch.ChannelInputStream.read(ChannelInputStream.java:103)
> at
> java.nio.channels.Channels$ReadableByteChannelImpl.read(Channels.java:385)
> at
> org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:85)
> at
> kafka.network.BlockingChannel.readCompletely(BlockingChannel.scala:129)
> at kafka.network.BlockingChannel.receive(BlockingChannel.scala:120)
> at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:100)
> at
> kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:84)
> at
> kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:133)
> at
> kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:133)
> at
> kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:133)
> at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:32)
> at
> kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:132)
> at
> kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:132)
> at
> kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:132)
> at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:32)
> at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:131)
> at
> kafka.api.ProducerBounceTest$$anonfun$2.apply(ProducerBounceTest.scala:116)
> at
> kafka.api.ProducerBounceTest$$anonfun$2.apply(ProducerBounceTest.scala:113)
> {noformat}
> This is expected occasionally, since the ports are preallocated and the
> brokers are bounced in quick succession. Here is the relevant comment from
> the code:
> {noformat}
> // This is the one of the few tests we currently allow to preallocate
> ports, despite the fact that this can result in transient
> // failures due to ports getting reused. We can't use random ports because
> of bad behavior that can result from bouncing
> // brokers too quickly when they get new, random ports. If we're not
> careful, the client can end up in a situation
> // where metadata is not refreshed quickly enough, and by the time it's
> actually trying to, all the servers have
> // been bounced and have new addresses. None of the bootstrap nodes or
> current metadata can get them connected to a
> // running server.
> //
> // Since such quick rotation of servers is incredibly unrealistic, we allow
> this one test to preallocate ports, leaving
> // a small risk of hitting errors due to port conflicts. Hopefully this is
> infrequent enough to not cause problems.
> {noformat}
> We should try to look into handling this exception better so that the test
> doesn't fail occasionally.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
