1
こんにちは、このコマンドを実行しています。kafka-topics --zookeeper localhost - 削除 - - トピックMyTopickafkaトピックを完全に削除するには？
これは動作します。
[2016-06-28 14:22:43,533] INFO Deleting index /data1/kafka/MyTopic-XX/00000000000000000000.index (kafka.log.OffsetIndex)
[2016-06-28 14:22:43,533] INFO Deleted log for partition [MyTopic,xx] in /data1/kafka/MyTopic-xx. (kafka.log.LogManager)
ここで、XXはパーティションです。 kafkaのログディレクトリを見ると、そのトピックは削除されますが、数分後に再び表示されます。
私は私が見るカフカのログを見て...
INFO Created log for partition [MyTopic,XX] in /data1/kafka with properties {compression.type -> producer, message.format.version -> 0.10.0-IV1, file.delete.delay.ms -> 60000, max.message.bytes -> 1000012, message.timestamp.type -> CreateTime, min.insync.replicas -> 1, segment.jitter.ms -> 0, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> true, retention.bytes -> -1, delete.retention.ms -> 86400000, cleanup.policy -> delete, flush.ms -> 9223372036854775807, segment.ms -> 604800000, segment.bytes -> 1073741824, retention.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760, flush.messages -> 9223372036854775807}. (kafka.log.LogManager)
[2016-06-28 13:59:39,623] INFO Partition [MyTopic,XX] on broker 0: No checkpointed highwatermark is found for partition [MyTopic,XX] (kafka.cluster.Partition)
だから、何とかそれを再作成しているようですか？
おかげ
トピックの削除オプションは、デフォルトでは無効になっています。これを有効にするには、サーバの設定delete.topic.enable = trueを設定し、カフカを再起動します。 bin/kafka-topics.sh --zookeeper zk_host：port/chroot --delete --topic my_topic_name – srujana
それ以外の場合は、どうして物理的にフォルダを削除してから再作成するのですか？ – user432024
また、私はあなたと同じ唯一の違いを述べたのと全く同じコマンドを実行しました。私はchrootです。 – user432024