バッチリスナー - 0.9.1

Question

私はバッチリスナーが

はバージョン1.0.6.RELEASEでレコードのバッチを受信することが可能であり、以降1.1.RELEASEをサポートしています参照してください。私たちのカフカサーバーはまだkafka-clients-0.9.1にあります。したがって、サーバーがアップグレードされるまでクライアントをアップグレードすることはできません。

@KafkaListener(id = "batch-listener", topics = "${kafka.topic.name}", containerFactory = "kafkaListenerContainerFactory") 
public void receive(ConsumerRecords<String, String> eventList) {} 

は、上記のコードを試みたが、

Answer 1

バッチリスナーが1.1.xの中に添加したConsumerRecordに文字列を変換しつつ、MessageConversionExceptionに失敗しています。 1.0.xでは利用できません。

バッチリスナーは、ConsumerRecordsではないList<ConsumerRecord<?,?>>を受信することに注意してください。