2016-08-05 12 views
1

カフカトピックのログサイズを制限しようとしています。カフカの特定のトピックのログサイズを制限する

私はカフカのドキュメント(カフカ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に設定します。 しかし、メッセージは追加され続けます。

これを達成するために追加の設定が必要ですか?

答えて

0

log.segment.bytes(デフォルトは1073741824バイト)をご確認ください。私が知る限り、ログセグメントがロールバックされるときに保持が考慮されます。

達成しようとしていることを説明できますか?なぜそれを削除するメッセージを送信する?

+0

私は 'segment.bytes'を15バイトに変更しようとしました。しかし、まだ成功はありません。 トピックごとにサイズを制限しようとしました。同じカフカクラスタを複数のユーザーで共有することができます。私は 'retention.bytes = 1'を保持して、コンソールのコンシューマ自体を使ってこの機能を検証できるようにしました。 –

+0

それには何らかの影響がありますか? – TobiSH

関連する問題