4

私はカフカが初めてです。csv ファイルから Kafka にデータをインポートしようとしています。前日のデータが廃止されている間、毎日インポートする必要があります。PythonでKafkaトピックの下にあるすべてのメッセージを削除するにはどうすればよいですか? または、PythonでKafkaトピックを削除するにはどうすればよいですか? または、誰かがデータの有効期限が切れるまで待つことを提案しているのを見ました。可能であれば、データの有効期限を設定するにはどうすればよいですか? どんな提案でも大歓迎です！

ありがとう

4

2 に答える 2

2

最も簡単な方法は、トピックを削除することです。特定のテスト メッセージのセットが Kafka を介して送信されることを確認したい Python 自動テスト スイートでこれを使用し、以前のテスト実行の結果を見たくない

def delete_kafka_topic(topic_name):
    call(["/usr/bin/kafka-topics", "--zookeeper", "zookeeper-1:2181", "--delete", "--topic", topic_name])
于 2018-02-27T23:22:15.330 に答える