Editar FYI:exemplo de trabalho do gitHub

Eu estava pesquisando na Internet e não consegui encontrar um exemplo simples e funcional de um teste Kafka incorporado.

Minha configuração é:

Bota de molaMúltiplo@KafkaListener com tópicos diferentes em uma classeKafka incorporado para teste que está começando bemTeste com o Kafkatemplate que está enviando para o tópico, mas o@KafkaListener métodos não estão recebendo nada, mesmo após um enorme período de sonoNenhum aviso ou erro é mostrado, apenas informações spam de Kafka nos logs

Por favor me ajude. Na maioria dos casos, existem exemplos configurados ou superengenharia. Estou certo de que isso pode ser feito de maneira simples. Obrigado rapazes!

@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
    }
}

estática privada String 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);
    }