kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Vitaly Larchenkov <vitaly.larchen...@gmail.com>
Subject Batch handling - value is null in consumer record
Date Tue, 05 Sep 2017 09:12:39 GMT
Hello,
I have Spring Boot app that implements @KafkaListener. I decide to use
batches for better performance.

I add few changes to config:

    factory.setBatchListener(true);

and add batch size.

Also I change kafka listener to receive batches, this is signature of
method:

    public void receive(List<ConsumerRecord<String, MyData>> r,
Acknowledgment acknowledgment)

With previous listener data deserialize like expected, all works fine. But
after changes value field is null. Offsets acknowledgment all works but no
data.

I found pretty old issue on github
https://github.com/spring-projects/spring-kafka/issues/240 but version of
spring kafka that I use is 1.2.2.

 I well be glad for any advice. Thanks!

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message