[
https://issues.apache.org/jira/browse/KAFKA-627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar resolved KAFKA-627.
-----------------------------
Resolution: Fixed
Not observed on latest versions
> Make UnknownTopicOrPartitionException a WARN in broker
> ------------------------------------------------------
>
> Key: KAFKA-627
> URL: https://issues.apache.org/jira/browse/KAFKA-627
> Project: Kafka
> Issue Type: Bug
> Components: core
> Affects Versions: 0.8.0
> Environment: Kafka 0.8, RHEL6, Java 1.6
> Reporter: Chris Riccomini
>
> Currently, when sending messages to a topic that doesn't yet exist, the
> broker spews out these "errors" as it tries to auto-create new topics. I
> spoke with Neha, and she said that this should be a warning, not an error.
> Could you please change it to something less scary, if, in fact, it's not
> scary.
> 2012/11/14 22:38:53.238 INFO [LogManager] [kafka-request-handler-6] [kafka]
> [] [Log Manager on Broker 464] Created log for 'firehoseReads'-5
> 2012/11/14 22:38:53.241 WARN [HighwaterMarkCheckpoint]
> [kafka-request-handler-6] [kafka] [] No previously checkpointed
> highwatermark value found for topic firehoseReads partition 5. Returning 0 as
> the highwatermark
> 2012/11/14 22:38:53.242 INFO [Log] [kafka-request-handler-6] [kafka] []
> [Kafka Log on Broker 464], Truncated log segment
> /export/content/kafka/i001_caches/firehoseReads-5/00000000000000000000.log to
> target offset 0
> 2012/11/14 22:38:53.242 INFO [ReplicaFetcherManager]
> [kafka-request-handler-6] [kafka] [] [ReplicaFetcherManager on broker 464]
> adding fetcher on topic firehoseReads, partion 5, initOffset 0 to broker 466
> with fetcherId 0
> 2012/11/14 22:38:53.248 ERROR [ReplicaFetcherThread]
> [ReplicaFetcherThread-466-0-on-broker-464] [kafka] []
> [ReplicaFetcherThread-466-0-on-broker-464], error for firehoseReads 5 to
> broker 466
> kafka.common.UnknownTopicOrPartitionException
> at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native
> Method)
> at
> sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:39)
> at
> sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:27)
> at java.lang.reflect.Constructor.newInstance(Constructor.java:513)
> at java.lang.Class.newInstance0(Class.java:355)
> at java.lang.Class.newInstance(Class.java:308)
> at kafka.common.ErrorMapping$.exceptionFor(ErrorMapping.scala:68)
> at
> kafka.server.AbstractFetcherThread$$anonfun$doWork$5$$anonfun$apply$3.apply(AbstractFetcherThread.scala:124)
> at
> kafka.server.AbstractFetcherThread$$anonfun$doWork$5$$anonfun$apply$3.apply(AbstractFetcherThread.scala:124)
> at kafka.utils.Logging$class.error(Logging.scala:102)
> at kafka.utils.ShutdownableThread.error(ShutdownableThread.scala:23)
> at
> kafka.server.AbstractFetcherThread$$anonfun$doWork$5.apply(AbstractFetcherThread.scala:123)
> at
> kafka.server.AbstractFetcherThread$$anonfun$doWork$5.apply(AbstractFetcherThread.scala:99)
> at
> scala.collection.immutable.HashMap$HashMap1.foreach(HashMap.scala:125)
> at
> scala.collection.immutable.HashMap$HashTrieMap.foreach(HashMap.scala:344)
> at
> scala.collection.immutable.HashMap$HashTrieMap.foreach(HashMap.scala:344)
> at
> kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:99)
> at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:50)
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
