SpringKafka听众签名

Question

我试图通过stackoverflow搜索这个问题，但找不到合理的答案。我对@Kafkalistener注释的方法的签名很好奇，我们需要遵循什么约定吗？。如果我们想通过方法注入传入spring管理的bean呢？我试图通过方法注入将服务类传递给kafka侦听器-

private fun defaultListener(payload: ByteArray, @Headers messageHeaders: MessageHeaders, ack: Acknowledgment, callbackService: CallbackService) {
 // Do something
}

我得到以下例外-

org.springframework.messaging.converter.MessageConversionException: Cannot handle message; nested exception is org.springframework.messaging.converter.MessageConversionException: Cannot convert from [[B] to [com.test.kafka-demo.service.CallbackService]

如果我使相关服务类自动生成，工作正常。

Answer 1

侦听器方法中的所有参数都必须从消费者记录（或记录本身）、消费者和/或使用手动提交时的确认中派生。

@Payload（或无注释）从记录转换（如有必要）。value（）。

不能在那里添加任意bean引用。