[KAFKA-3876] Transient test failure: kafka.api.PlaintextConsumerTest.testExpandingTopicSubscriptions

• Type: Sub-task
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Component/s: unit tests
• Labels: transient-unit-test-failure
• Assignee: Unassigned
• Reporter: Ismael Juma
• Created: 20/Jun/16 13:02
• Updated: 05/Jul/16 23:32

Description

Failed in a recent build:

java.lang.AssertionError: Partition [__consumer_offsets,0] metadata not propagated after 5000 ms
	at org.junit.Assert.fail(Assert.java:88)
	at kafka.utils.TestUtils$.waitUntilTrue(TestUtils.scala:771)
	at kafka.utils.TestUtils$.waitUntilMetadataIsPropagated(TestUtils.scala:812)
	at kafka.utils.TestUtils$$anonfun$createTopic$1.apply(TestUtils.scala:240)
	at kafka.utils.TestUtils$$anonfun$createTopic$1.apply(TestUtils.scala:239)
	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
	at scala.collection.immutable.Range.foreach(Range.scala:160)
	at scala.collection.TraversableLike$class.map(TraversableLike.scala:234)
	at scala.collection.AbstractTraversable.map(Traversable.scala:104)
	at kafka.utils.TestUtils$.createTopic(TestUtils.scala:239)
	at kafka.api.IntegrationTestHarness$class.setUp(IntegrationTestHarness.scala:80)
	at kafka.api.BaseConsumerTest.setUp(BaseConsumerTest.scala:60)

Standard out:

[2016-06-19 09:09:20,081] WARN Client session timed out, have not heard from server in 4002ms for sessionid 0x15567ebcc160001 (org.apache.zookeeper.ClientCnxn:1108)
[2016-06-19 09:09:21,602] WARN caught end of stream exception (org.apache.zookeeper.server.NIOServerCnxn:357)
EndOfStreamException: Unable to read additional data from client sessionid 0x15567ebcc160001, likely client has closed socket
	at org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:230)
	at org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:203)
	at java.lang.Thread.run(Thread.java:745)
[2016-06-19 09:09:20,081] WARN Client session timed out, have not heard from server in 4001ms for sessionid 0x15567ebcc160003 (org.apache.zookeeper.ClientCnxn:1108)
[2016-06-19 09:09:21,598] WARN Client session timed out, have not heard from server in 4001ms for sessionid 0x15567ebcc160002 (org.apache.zookeeper.ClientCnxn:1108)
[2016-06-19 09:09:21,613] WARN caught end of stream exception (org.apache.zookeeper.server.NIOServerCnxn:357)
EndOfStreamException: Unable to read additional data from client sessionid 0x15567ebcc160003, likely client has closed socket
	at org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:230)
	at org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:203)
	at java.lang.Thread.run(Thread.java:745)
[2016-06-19 09:09:21,613] WARN caught end of stream exception (org.apache.zookeeper.server.NIOServerCnxn:357)
EndOfStreamException: Unable to read additional data from client sessionid 0x15567ebcc160002, likely client has closed socket
	at org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:230)
	at org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:203)
	at java.lang.Thread.run(Thread.java:745)
[2016-06-19 09:09:21,602] WARN Client session timed out, have not heard from server in 4084ms for sessionid 0x15567ebcc160000 (org.apache.zookeeper.ClientCnxn:1108)
[2016-06-19 09:09:21,615] WARN caught end of stream exception (org.apache.zookeeper.server.NIOServerCnxn:357)
EndOfStreamException: Unable to read additional data from client sessionid 0x15567ebcc160000, likely client has closed socket
	at org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:230)
	at org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:203)
	at java.lang.Thread.run(Thread.java:745)
[2016-06-19 09:11:26,866] WARN caught end of stream exception (org.apache.zookeeper.server.NIOServerCnxn:357)
EndOfStreamException: Unable to read additional data from client sessionid 0x15567edb4d10002, likely client has closed socket
	at org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:230)
	at org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:203)
	at java.lang.Thread.run(Thread.java:745)
[2016-06-19 09:11:29,171] ERROR [KafkaApi-0] Error when handling request Name: FetchRequest; Version: 2; CorrelationId: 0; ClientId: ReplicaFetcherThread-0-0; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [__consumer_offsets,0] -> PartitionFetchInfo(0,1048576) (kafka.server.KafkaApis:103)
kafka.common.NotAssignedReplicaException: Leader 0 failed to record follower 2's position -1 since the replica is not recognized to be one of the assigned replicas  for partition [__consumer_offsets,0].
	at kafka.cluster.Partition.updateReplicaLogReadResult(Partition.scala:251)
	at kafka.server.ReplicaManager$$anonfun$updateFollowerLogReadResults$2.apply(ReplicaManager.scala:864)
	at kafka.server.ReplicaManager$$anonfun$updateFollowerLogReadResults$2.apply(ReplicaManager.scala:861)
	at scala.collection.immutable.Map$Map1.foreach(Map.scala:116)
	at kafka.server.ReplicaManager.updateFollowerLogReadResults(ReplicaManager.scala:861)
	at kafka.server.ReplicaManager.fetchMessages(ReplicaManager.scala:470)
	at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:496)
	at kafka.server.KafkaApis.handle(KafkaApis.scala:77)
	at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:60)
	at java.lang.Thread.run(Thread.java:745)
[2016-06-19 09:11:29,171] ERROR [ReplicaFetcherThread-0-0], Error for partition [__consumer_offsets,0] to broker 0:org.apache.kafka.common.errors.UnknownServerException: The server experienced an unexpected error when processing the request (kafka.server.ReplicaFetcherThread:97)
[2016-06-19 09:11:47,714] WARN caught end of stream exception (org.apache.zookeeper.server.NIOServerCnxn:357)
EndOfStreamException: Unable to read additional data from client sessionid 0x15567ee0b4c0002, likely client has closed socket
	at org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:230)
	at org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:203)
	at java.lang.Thread.run(Thread.java:745)

https://jenkins.confluent.io/job/kafka-trunk/932/