Kafka 0.8.1.1 の server.properties ファイルに変更を加えました。つまり、トピックの作成中に追加log.cleaner.enable=trueして有効にしました。cleanup.policy=compact今テストしているとき、次のメッセージをトピックに次の（キー、メッセージ）でプッシュしました。
- オフセット: 1 - (123、abc);
- オフセット: 2 - (234、デフォルト);
- オフセット: 3 - (345, ghi);
- オフセット: 4 - (123、変更)
ここで、前の入力と同じキーで 4 番目のメッセージをプッシュしましたが、メッセージを変更しました。ここで、ログの圧縮が明らかになるはずです。Kafka ツールを使用すると、トピック内の 4 つのオフセットすべてを確認できます。ログの圧縮が機能しているかどうかを知るにはどうすればよいですか? 以前のメッセージを削除する必要があります。または、新しいメッセージがプッシュされているため、ログの圧縮が正常に機能しています。log.retention.hoursまたはtopic.log.retention.hoursまたはlog.retention.size構成と何か関係がありますか? ログの圧縮におけるこれらの構成の役割は何ですか。PS - Apache ドキュメントを徹底的に調べましたが、まだ明確ではありません。