[ 
https://issues.apache.org/jira/browse/KAFKA-3400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15208531#comment-15208531
 ] 

Tobias commented on KAFKA-3400:
-------------------------------

More research.
I've now setup a completely new cluster using auto.create topic.
The producers and consumers are version 0.8.2.1 and the brokers are 0.9.0.1
When the topics get auto created most of the topics don't get assigned 
partitions and after the initial message I see nothign else re these topics in 
the logs
Example (notice the empty Map for replica assignment)
{noformat}
INFO [TopicChangeListener on Controller 3]: New topics: [Set(AUDIT_EXPORT)], 
deleted topics: [Set()], new partition replica assignment [Map()] 
(kafka.controller.PartitionStateMachine$TopicChangeListener)
{noformat}

While the one Topic where it worked looks like this
{noformat}
[2016-03-23 14:43:39,740] INFO [TopicChangeListener on Controller 3]: New 
topics: [Set(EXCHANGE_RATE_EXPORT)], deleted topics: [Set()], new partition 
replica assignment [Map([EXCHANGE_RATE_EXPORT,1] -> List(3, 1, 2), 
[EXCHANGE_RATE_EXPORT,6] -> List(2, 3, 1), [EXCHANGE_RATE_EXPORT,0] -> List(2, 
3, 1), [EXCHANGE_RATE_EXPORT,5] -> List(1, 3, 2), [EXCHANGE_RATE_EXPORT,4] -> 
List(3, 2, 1), [EXCHANGE_RATE_EXPORT,7] -> List(3, 1, 2), 
[EXCHANGE_RATE_EXPORT,2] -> List(1, 2, 3), [EXCHANGE_RATE_EXPORT,3] -> List(2, 
1, 3))] (kafka.controller.PartitionStateMachine$TopicChangeListener)
[2016-03-23 14:43:39,741] INFO [Controller 3]: New topic creation callback for 
[EXCHANGE_RATE_EXPORT,1],[EXCHANGE_RATE_EXPORT,2],[EXCHANGE_RATE_EXPORT,7],[EXCHANGE_RATE_EXPORT,0],[EXCHANGE_RATE_EXPORT,5],[EXCHANGE_RATE_EXPORT,6],[EXCHANGE_RATE_EXPORT,4],[EXCHANGE_RATE_EXPORT,3]
 (kafka.controller.KafkaController)
{noformat}

> Topic stop working / can't describe topic
> -----------------------------------------
>
>                 Key: KAFKA-3400
>                 URL: https://issues.apache.org/jira/browse/KAFKA-3400
>             Project: Kafka
>          Issue Type: Bug
>    Affects Versions: 0.9.0.1
>            Reporter: Tobias
>            Assignee: Ashish K Singh
>             Fix For: 0.10.1.0
>
>
> we are seeing an issue were we intermittently (every couple of hours) get and 
> error with certain topics. They stop working and producers give a 
> LeaderNotFoundException.
> When we then try to use kafka-topics.sh to describe the topic we get the 
> error below.
> Error while executing topic command : next on empty iterator
> {{
> [2016-03-15 17:30:26,231] ERROR java.util.NoSuchElementException: next on 
> empty iterator
>       at scala.collection.Iterator$$anon$2.next(Iterator.scala:39)
>       at scala.collection.Iterator$$anon$2.next(Iterator.scala:37)
>       at scala.collection.IterableLike$class.head(IterableLike.scala:91)
>       at scala.collection.AbstractIterable.head(Iterable.scala:54)
>       at 
> kafka.admin.TopicCommand$$anonfun$describeTopic$1.apply(TopicCommand.scala:198)
>       at 
> kafka.admin.TopicCommand$$anonfun$describeTopic$1.apply(TopicCommand.scala:188)
>       at 
> scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59)
>       at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47)
>       at kafka.admin.TopicCommand$.describeTopic(TopicCommand.scala:188)
>       at kafka.admin.TopicCommand$.main(TopicCommand.scala:66)
>       at kafka.admin.TopicCommand.main(TopicCommand.scala)
>  (kafka.admin.TopicCommand$)
> }}
> if we delete the topic, then it will start to work again for a while
> We can't see anything obvious in the logs but are happy to provide if needed



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to