[解決済み] 削除マークがついたトピックはいつ、どのように削除されるのですか?
2023-06-23 14:46:39
質問
トピックを削除するコマンドを発行しました。
./bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic vip_ips_alerts
嬉しい反応があったようです。
[2014-05-31 20:58:10,112] INFO zookeeper state changed (SyncConnected) (org.I0Itec.zkclient.ZkClient)
Topic "vip_ips_alerts" queued for deletion.
しかし、10分後の現在、トピックはまだ
--list
コマンドで表示されます。
./bin/kafka-topics.sh --zookeeper localhost:2181 --list
vip_ips_alerts - marked for deletion
ということは、どういうことなのでしょうか? いつになったら、この話題は 本当に 削除されるのでしょうか? どうすればこのプロセスを早めることができますか?
どのように解決するのですか?
tl;dr
設定
delete.topic.enable = true
で
config/server.properties
のKafkaブローカーで、...我慢してください。
Kafkaの最新の開発版で発生する 0.8.3-SNAPSHOT :
➜ kafka_2.11-0.8.3-SNAPSHOT git:(trunk) ✗ ./bin/kafka-topics.sh --zookeeper localhost:2181 --create --topic my-topic --partitions 2 --replication-factor 1
Created topic "my-topic".
➜ kafka_2.11-0.8.3-SNAPSHOT git:(trunk) ✗ ./bin/kafka-topics.sh --zookeeper localhost:2181 --describe --topic my-topic
Topic:my-topic PartitionCount:2 ReplicationFactor:1 Configs:
Topic: my-topic Partition: 0 Leader: 0 Replicas: 0 Isr: 0
Topic: my-topic Partition: 1 Leader: 0 Replicas: 0 Isr: 0
➜ kafka_2.11-0.8.3-SNAPSHOT git:(trunk) ✗ ./bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic my-topic
Topic my-topic is marked for deletion.
Note: This will have no impact if delete.topic.enable is not set to true.
➜ kafka_2.11-0.8.3-SNAPSHOT git:(trunk) ✗ ./bin/kafka-topics.sh --zookeeper localhost:2181 --list
➜ kafka_2.11-0.8.3-SNAPSHOT git:(trunk) ✗
ポイントは
delete.topic.enable=true
で
config/server.properties
で、Kafkaブローカーを起動するために使用します。
➜ kafka_2.11-0.8.3-SNAPSHOT git:(trunk) ✗ grep delete.topic.enable config/server.properties
delete.topic.enable=true
また、ブローカーのログで設定がtrueであることを確認することもできます。
➜ kafka_2.11-0.8.3-SNAPSHOT git:(trunk) ✗ ./bin/kafka-server-start.sh config/server.properties
[2015-07-24 22:33:26,184] INFO KafkaConfig values:
...
delete.topic.enable = true
関連
-
[解決済み] Kafkaメッセージにカスタムヘッダを追加する
-
[解決済み] kafkaとnifiの違い
-
[解決済み] HDFスキーマレジストリとConfluentの主な違いは何ですか?
-
[解決済み] JAAS または Kafka の設定に serviceName が定義されていない (Kerberos ではない)
-
[解決済み] Apache Kafkaのコンテキストで「Rebalancing」とはどういう意味ですか?
-
[解決済み】Kafkaトピックのパージ
-
[解決済み] Kafkaでデータモデリング?トピックとパーティション
-
[解決済み] Kafka 0.8.1.1でのトピックの削除
-
[解決済み] カフカメッセージを表示する方法
-
[解決済み] Kafkaトピックのレプリカの数を変更するにはどうすればよいですか?
最新
-
nginxです。[emerg] 0.0.0.0:80 への bind() に失敗しました (98: アドレスは既に使用中です)
-
htmlページでギリシャ文字を使うには
-
ピュアhtml+cssでの要素読み込み効果
-
純粋なhtml + cssで五輪を実現するサンプルコード
-
ナビゲーションバー・ドロップダウンメニューのHTML+CSSサンプルコード
-
タイピング効果を実現するピュアhtml+css
-
htmlの選択ボックスのプレースホルダー作成に関する質問
-
html css3 伸縮しない 画像表示効果
-
トップナビゲーションバーメニュー作成用HTML+CSS
-
html+css 実装 サイバーパンク風ボタン
おすすめ
-
[解決済み] Kafkaメッセージにカスタムヘッダを追加する
-
[解決済み] kafkaとnifiの違い
-
[解決済み] Kafkaのキー/バリューペアベースのメッセージングは何のためにあるのですか?[クローズド]
-
[解決済み] Zookeeperにアクセスせずに-zookeeperフラグを使用してKafka 0.10トピックをすべて一覧表示する
-
[解決済み] Apache Kafkaのコンテキストで「Rebalancing」とはどういう意味ですか?
-
[解決済み] KafkaよりRabbitMQを使うべきタイミングは?[クローズド]
-
[解決済み] カフカ コンシューマーAPIとストリームAPI
-
[解決済み] トピックのデータをすべて削除したり、毎回実行する前にトピックを削除する方法はありますか?
-
[解決済み] クラスタ内の利用可能なすべてのKafkaブローカーを一覧表示するには?
-
[解決済み] Kafkaコンシューマーリスト