¿Hay una manera de eliminar todos los datos de un tema o eliminar el tema antes de cada ejecución?

¿Puedo modificar el archivo KafkaConfig.scala para cambiar ellogRetentionHours ¿propiedad? ¿Hay alguna manera de que los mensajes se borren tan pronto como el consumidor los lea?

Estoy utilizando productores para obtener los datos de algún lugar y enviarlos a un tema en particular que consume un consumidor. ¿Puedo eliminar todos los datos de ese tema en cada ejecución? Sólo quiero nuevos datos cada vez que en el tema. ¿Hay alguna manera de reinicializar el tema de alguna manera?