カフカトピックのログサイズを制限しようとしています。カフカの特定のトピックのログサイズを制限する
私はカフカのドキュメント(カフカ0.10.0ドキュメント)を踏襲し、削除=これら二つのプロパティcleanup.policyを設定し、retention.bytes = 1。
- 話題の>結果describeコマンド
./kafka-topics.sh --describe --zookeeperはlocalhost:2181 --topic kafkatest1トピック:kafkatest1のPartitionCount:3
ReplicationFactor: 1
Configsに:cleanup.policy =削除、retention.bytes = 1
私が設定しているので、私は、トピックに「kafkatest1」を書いていますどのようなメッセージが自動的に削除されますことを期待していましたretention.bytesを1に設定します。 しかし、メッセージは追加され続けます。
これを達成するために追加の設定が必要ですか?
私は 'segment.bytes'を15バイトに変更しようとしました。しかし、まだ成功はありません。 トピックごとにサイズを制限しようとしました。同じカフカクラスタを複数のユーザーで共有することができます。私は 'retention.bytes = 1'を保持して、コンソールのコンシューマ自体を使ってこの機能を検証できるようにしました。 –
それには何らかの影響がありますか? – TobiSH