Есть ли способ удалить все данные из темы или удалить тему перед каждым запуском?
Можно ли изменить файл KafkaConfig.scala, чтобы изменить свойство logRetentionHours
? Есть ли способ, по которому сообщения удаляются, как только потребитель читает его?
Я использую производителей для получения данных откуда-то и отправки данных в конкретную тему, где потребитель потребляет, могу ли я удалить все данные из этой темы при каждом запуске? Я хочу только новые данные каждый раз в теме. Есть ли способ повторной инициализации темы?