Как принудительно сжать журнал темы Кафки?

#apache-kafka #апач-кафка Вопрос: Используя Кафку 2.7.0 (в K8s), я создаю тестовую тему с cleanup.policy=compact : ./kafka-topics.sh --create --bootstrap-server kafka.core-kafka.svc.cluster.local:9092 --topic _test_quick_compaction_2021_12_02 --partitions 1 --replication-factor 3 --config cleanup.policy=compact Напишите ему несколько…

Продолжить чтениеКак принудительно сжать журнал темы Кафки?