while consuming messages from kafka in batches of 1000 messages, using
springboot application, sometimes the following error(exception) is
occuring, Please help me find reason for this error and how to solve it .


ERROR(Exception):

"level":"ERROR","thread":"org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1","logger":"com.exception.KafkaCommonErrorHandler","message":"'handleBatch'
is not implemented by this
handler","exception":"org.springframework.kafka.listener.ListenerExecutionFailedException:
Listener method 'public void
com.service.ConsumerService.processMessage(java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<java.lang.String,
com.model.DTO>>,org.springframework.kafka.support.Acknowledgment)' threw
exception; nested exception is java.lang.NullPointerException; nested
exception is java.lang.NullPointerException\n\tat
org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.decorateException(KafkaMessageListenerContainer.java:2638)\n\tat
org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeBatchOnMessage(KafkaMessageListenerContainer.java:2267)\n\tat
org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeBatchOnMessageWithRecordsOrList(KafkaMessageListenerContainer.java:2237)\n\tat
org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeBatchOnMessage(KafkaMessageListenerContainer.java:2183)\n\tat
org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeBatchListener(KafkaMessageListenerContainer.java:2093)\n\tat
org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeBatchListener(KafkaMessageListenerContainer.java:1976)\n\tat
org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1955)\n\tat
org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeIfHaveRecords(KafkaMessageListenerContainer.java:1353)\n\tat
org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1344)\n\tat
org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1236)\n\tat
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)\n\tat
java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)\n\tat
java.base/java.lang.Thread.run(Thread.java:829)\n\tSuppressed:
org.springframework.kafka.listener.ListenerExecutionFailedException:
Restored Stack Trace\n\t\tat
org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:363)\n\t\tat
org.springframework.kafka.listener.adapter.BatchMessagingMessageListenerAdapter.invoke(BatchMessagingMessageListenerAdapter.java:180)\n\t\tat
org.springframework.kafka.listener.adapter.BatchMessagingMessageListenerAdapter.onMessage(BatchMessagingMessageListenerAdapter.java:172)\n\t\tat
org.springframework.kafka.listener.adapter.BatchMessagingMessageListenerAdapter.onMessage(BatchMessagingMessageListenerAdapter.java:61)\n\t\tat
org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeBatchOnMessage(KafkaMessageListenerContainer.java:2247)\nCaused
by: java.lang.NullPointerException: null\n"

Reply via email to