Инструмент сброса приложения Kafka Streams не удаляет внутренние темы - PullRequest
0 голосов
/ 10 ноября 2018

У меня проблемы с использованием инструмента сброса приложений в Kafka Streams. Kafka streams создает внутренние темы для моих потоков, которые имеют свойство config cleanup.policy , которое по умолчанию delete для темы перераспределения и compact для темы журнала изменений. Но я замечаю, что в одной из наших сред разработки темы не имеют этих настроек. И как таковой инструмент сброса не удаляет эти темы. Даже когда я вручную изменяю конфигурацию для этих тем, она возвращается к отсутствию конфигурации для некоторых из них. Любая идея, что может случиться. Это странное поведение, которое только началось само по себе. Я бегу Кафка 1.0

...