小编Yun*_*ska的帖子

编辑FYI:工作gitHub示例

我在互联网上搜索,找不到嵌入式Kafka测试的工作简单示例.

我的设置是:

• 春天的靴子
• 多个@KafkaListener,在一个类中包含不同的主题
• 嵌入式Kafka进行测试,开始很好
• 使用Kafkatemplate进行测试,发送到主题,但 @KafkaListener方法即使在很长的睡眠时间后也没有收到任何内容
• 没有显示警告或错误,只有日志中来自Kafka的垃圾邮件

请帮我.主要是过度配置或过度设计的示例.我相信它可以做得很简单.多谢你们!

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

private static String SENDER_TOPIC ="test.kafka.topic";

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

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