Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka >> mail # user >> kafka.common.UnknownTopicOrPartitionException


Copy link to this message
-
Re: kafka.common.UnknownTopicOrPartitionException
Any error in the controller and state-change log?

Thanks,

Jun
On Tue, Oct 8, 2013 at 5:41 AM, Snehalata Nagaje <
[EMAIL PROTECTED]> wrote:

> Hi ,
>
> I am getting below exception when I consume any message from given topic,
> when I checked the log file,, topic is already exist in kafak server. still
> It is giving the exceptions.
>
>
> kafka.common.UnknownTopicOrPartitionException: Topic
> topic_c7d4daa8-cdfd-40e6-b3de-a31b3ae30de9 partition 0 doesn't exist on 0
>         at
> kafka.server.ReplicaManager.getLeaderReplicaIfLocal(ReplicaManager.scala:170)
>         at kafka.server.KafkaApis$$anonfun$14.apply(KafkaApis.scala:330)
>         at kafka.server.KafkaApis$$anonfun$14.apply(KafkaApis.scala:325)
>         at
> scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206)
>         at
> scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206)
>         at scala.collection.immutable.Map$Map1.foreach(Map.scala:105)
>         at
> scala.collection.TraversableLike$class.map(TraversableLike.scala:206)
>         at scala.collection.immutable.Map$Map1.map(Map.scala:93)
>         at kafka.server.KafkaApis.handleOffsetRequest(KafkaApis.scala:325)
>         at kafka.server.KafkaApis.handle(KafkaApis.scala:62)
>         at
> kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:41)
>         at java.lang.Thread.run(Thread.java:679)
>
> This problem has started after changing the zookeeper instance , actually
> we have pointed kafka to new zookeeper instance.
>
> Thanks,
> Snehalata
> Disclaimer:
> This e-mail may contain Privileged/Confidential information and is
> intended only for the individual(s) named. Any review, retransmission,
> dissemination or other use of, or taking of any action in reliance upon
> this information by persons or entities other than the intended recipient
> is prohibited. Please notify the sender, if you have received this e-mail
> by mistake and delete it from your system. Information in this message that
> does not relate to the official business of the company shall be understood
> as neither given nor endorsed by it. E-mail transmission cannot be
> guaranteed to be secure or error-free. The sender does not accept liability
> for any errors or omissions in the contents of this message which arise as
> a result of e-mail transmission. If verification is required please request
> a hard-copy version. Visit us at http://www.harbingergroup.com/
>
>

 
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB