Есть ли способ удалить все данные из темы или удалить тему перед каждым запуском?

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

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