[jira] [Created] (KAFKA-6973) setting invalid timestamp causes Kafka broker restart to fail

[Paul Brebner (JIRA)]

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)