Editar FYI:ejemplo de trabajo de gitHub

Estaba buscando en Internet y no pude encontrar un ejemplo funcional y simple de una prueba de Kafka integrada.

Mi configuración es:

Bota de primaveraMúltiple@KafkaListener con diferentes temas en una claseKafka integrado para la prueba que está comenzando bienPrueba con Kafkatemplate que se envía al tema pero el@KafkaListener los métodos no reciben nada incluso después de un tiempo de sueño enormeNo se muestran advertencias ni errores, solo información spam de Kafka en los registros

Por favor, ayúdame. En su mayoría, hay ejemplos sobreconfigurados o de ingeniería excesiva. Estoy seguro de que se puede hacer simple. ¡Gracias chicos!

@Controller
public class KafkaController {

    private static final Logger LOG = getLogger(KafkaController.class);

    @KafkaListener(topics = "test.kafka.topic")
    public void receiveDunningHead(final String payload) {
        LOG.debug("Receiving event with payload [{}]", payload);
        //I will do database stuff here which i could check in db for testing
    }
}

Cadena estática privada SENDER_TOPIC = "test.kafka.topic";

@ClassRule
public static KafkaEmbedded embeddedKafka = new KafkaEmbedded(1, true, SENDER_TOPIC);

@Test
    public void testSend() throws InterruptedException, ExecutionException {

        Map<String, Object> senderProps = KafkaTestUtils.producerProps(embeddedKafka);

        KafkaProducer<Integer, String> producer = new KafkaProducer<>(senderProps);
        producer.send(new ProducerRecord<>(SENDER_TOPIC, 0, 0, "message00")).get();
        producer.send(new ProducerRecord<>(SENDER_TOPIC, 0, 1, "message01")).get();
        producer.send(new ProducerRecord<>(SENDER_TOPIC, 1, 0, "message10")).get();
        Thread.sleep(10000);
    }