spring-kafka监听器签名

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

在使用手动提交时，侦听器方法中的所有参数必须派生自ConsumerRecord (或记录本身)+使用者和/或确认。

从record.value()转换(如有必要) @Payload (或不转换注释)。

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