Blocker Description
I think this is probably a test issue, but setting as "Blocker" until we can confirm that.
Error org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for output-topic-0: 10467 ms has passed since batch creation plus linger time Stacktrace org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for output-topic-0: 10467 ms has passed since batch creation plus linger time Standard Output [2017-10-05 00:29:31,327] ERROR ZKShutdownHandler is not registered, so ZooKeeper server won't take any action on ERROR or SHUTDOWN server state changes (org.apache.zookeeper.server.ZooKeeperServer:472) [2017-10-05 00:29:31,877] ERROR [ReplicaFetcher replicaId=0, leaderId=1, fetcherId=0] Error for partition input-topic-0 to broker %1:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread:101) [2017-10-05 00:29:31,877] ERROR [ReplicaFetcher replicaId=3, leaderId=1, fetcherId=0] Error for partition input-topic-0 to broker %1:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread:101) [2017-10-05 00:29:31,877] ERROR [ReplicaFetcher replicaId=0, leaderId=2, fetcherId=0] Error for partition input-topic-1 to broker %2:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread:101) [2017-10-05 00:29:32,268] ERROR [ReplicaFetcher replicaId=0, leaderId=1, fetcherId=0] Error for partition output-topic-1 to broker %1:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread:101) [2017-10-05 00:29:32,284] ERROR [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Error for partition output-topic-1 to broker %1:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread:101) [2017-10-05 00:29:44,283] ERROR [KafkaApi-0] Error when handling request {controller_id=0,controller_epoch=1,delete_partitions=false,partitions=[{topic=input-topic,partition=1}]} (kafka.server.KafkaApis:107) java.util.NoSuchElementException: key not found: NONE at scala.collection.MapLike$class.default(MapLike.scala:228) at scala.collection.AbstractMap.default(Map.scala:59) at scala.collection.mutable.HashMap.apply(HashMap.scala:65) at kafka.network.RequestMetrics.markErrorMeter(RequestChannel.scala:410) at kafka.network.RequestChannel$$anonfun$updateErrorMetrics$1.apply(RequestChannel.scala:315) at kafka.network.RequestChannel$$anonfun$updateErrorMetrics$1.apply(RequestChannel.scala:314) at scala.collection.Iterator$class.foreach(Iterator.scala:891) at scala.collection.AbstractIterator.foreach(Iterator.scala:1334) at scala.collection.IterableLike$class.foreach(IterableLike.scala:72) at scala.collection.AbstractIterable.foreach(Iterable.scala:54) at kafka.network.RequestChannel.updateErrorMetrics(RequestChannel.scala:314) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$sendResponse$1.apply(KafkaApis.scala:2092) at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$sendResponse$1.apply(KafkaApis.scala:2092) at scala.Option.foreach(Option.scala:257) at kafka.server.KafkaApis.kafka$server$KafkaApis$$sendResponse(KafkaApis.scala:2092) at kafka.server.KafkaApis.sendResponseExemptThrottle(KafkaApis.scala:2061) at kafka.server.KafkaApis.handleStopReplicaRequest(KafkaApis.scala:202) at kafka.server.KafkaApis.handle(KafkaApis.scala:104) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:65)
Attachments
Issue Links
- links to
