[
https://issues.apache.org/jira/browse/KAFKA-627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15146725#comment-15146725
]
ASF GitHub Bot commented on KAFKA-627:
--------------------------------------
GitHub user kichristensen opened a pull request:
https://github.com/apache/kafka/pull/913
KAFKA-627: Make UnknownTopicOrPartitionException a WARN in broker
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/kichristensen/kafka KAFKA-627
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/913.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #913
----
commit 9dc94fc95ceed94bd14cffa321023c902b11e19d
Author: Kim Christensen <[email protected]>
Date: 2016-02-14T20:45:13Z
UnknownTopicOrPartition should be logged as warn
----
> 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.3.4#6332)
