diff --git a/core/src/main/scala/kafka/admin/TopicCommand.scala b/core/src/main/scala/kafka/admin/TopicCommand.scala index f400b71..1981224 100644 --- a/core/src/main/scala/kafka/admin/TopicCommand.scala +++ b/core/src/main/scala/kafka/admin/TopicCommand.scala @@ -145,7 +145,7 @@ object TopicCommand { try { ZkUtils.createPersistentPath(zkClient, ZkUtils.getDeleteTopicPath(topic)) println("Topic %s is marked for deletion.".format(topic)) - println("Note: This will have no impact if delete.topic.enable is not set to true.") + println("Note: This will have no impact if delete.topic.enable is set to false.") } catch { case e: ZkNodeExistsException => println("Topic %s is already marked for deletion.".format(topic)) diff --git a/core/src/main/scala/kafka/server/KafkaConfig.scala b/core/src/main/scala/kafka/server/KafkaConfig.scala index 14bf321..c1a9d4c 100644 --- a/core/src/main/scala/kafka/server/KafkaConfig.scala +++ b/core/src/main/scala/kafka/server/KafkaConfig.scala @@ -348,8 +348,8 @@ class KafkaConfig private (val props: VerifiableProperties) extends ZKConfig(pro val offsetCommitRequiredAcks = props.getShortInRange("offsets.commit.required.acks", OffsetManagerConfig.DefaultOffsetCommitRequiredAcks, (-1, offsetsTopicReplicationFactor)) - /* Enables delete topic. Delete topic through the admin tool will have no effect if this config is turned off */ - val deleteTopicEnable = props.getBoolean("delete.topic.enable", false) + /* Enables delete topic. Delete topic through the admin tool will have no effect if this config is set to false */ + val deleteTopicEnable = props.getBoolean("delete.topic.enable", true) /** * Specify the final compression type for a given topic. This configuration accepts the standard compression codecs