You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Paul Brebner (JIRA)" <ji...@apache.org> on 2018/05/31 04:00:00 UTC
[jira] [Created] (KAFKA-6973) setting invalid timestamp causes
Kafka broker restart to fail
Paul Brebner created KAFKA-6973:
-----------------------------------
Summary: setting invalid timestamp causes Kafka broker restart to fail
Key: KAFKA-6973
URL: https://issues.apache.org/jira/browse/KAFKA-6973
Project: Kafka
Issue Type: Bug
Components: admin
Affects Versions: 1.1.0
Reporter: Paul Brebner
Setting timestamp to invalid value causes Kafka broker to fail upon startup. E.g.
./kafka-topics.sh --create --zookeeper localhost --topic duck3 --partitions 1 --replication-factor 1 --config message.timestamp.type=boom
Also note that the docs says the parameter name is log.message.timestamp.type, but this is silently ignored.
This works with no error for the invalid timestamp value. But next time you restart Kafka:
[2018-05-29 13:09:05,806] FATAL [KafkaServer id=0] Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)
java.util.NoSuchElementException: Invalid timestamp type boom
at org.apache.kafka.common.record.TimestampType.forName(TimestampType.java:39)
at kafka.log.LogConfig.<init>(LogConfig.scala:94)
at kafka.log.LogConfig$.fromProps(LogConfig.scala:279)
at kafka.log.LogManager$$anonfun$17.apply(LogManager.scala:786)
at kafka.log.LogManager$$anonfun$17.apply(LogManager.scala:785)
at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
at scala.collection.immutable.HashMap$HashMap1.foreach(HashMap.scala:221)
at scala.collection.immutable.HashMap$HashTrieMap.foreach(HashMap.scala:428)
at scala.collection.immutable.HashMap$HashTrieMap.foreach(HashMap.scala:428)
at scala.collection.TraversableLike$class.map(TraversableLike.scala:234)
at scala.collection.AbstractTraversable.map(Traversable.scala:104)
at kafka.log.LogManager$.apply(LogManager.scala:785)
at kafka.server.KafkaServer.startup(KafkaServer.scala:222)
at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:38)
at kafka.Kafka$.main(Kafka.scala:92)
at kafka.Kafka.main(Kafka.scala)
[2018-05-29 13:09:05,811] INFO [KafkaServer id=0] shutting down
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)