- 前言
- 一、消息如何传递给方法
- 二、方法入参转换
- 三、方法入参演示
-
- 1.单条消息消费
- 2.批量消息消费
- 总结
上一篇博文中，我们通过KafkaListener注解标记的方法，并使用List入参，接收传递的消息，模拟业务逻辑处理。各位读者，估计会有一个问题，方法上可以使用那些参数来代表消息呢？这篇博文，将进行解答。
一、消息如何传递给方法消费者拉取消息后，通过invokeListener方法，内部通过invoke等一系列方法，最终到达InvocableHandlerMethod.invoke，在其内部，将参数转换成KafkaListener注解标记的方法所需的参数后，进行执行。具体逻辑，我们将在后续博文，进行梳理和介绍，此处，只关心消息传递相关的代码。
// ListenerConsumer处理类 protected void
