Existe uma maneira de excluir todos os dados de um tópico ou excluir o tópico antes de cada execução?

Posso modificar o arquivo KafkaConfig.scala para alterar ologRetentionHours propriedade? Existe uma maneira de as mensagens serem excluídas assim que o consumidor as lê?

Eu estou usando produtores para buscar os dados de algum lugar e enviar os dados para um determinado tópico onde um consumidor consome, posso excluir todos os dados desse tópico em todas as execuções? Eu quero apenas novos dados toda vez no tópico. Existe uma maneira de reinicializar o tópico de alguma forma?