Consumer side help requirement

2020-08-17 Thread Preethkumar Thirupathi
Hi Team,

I want to develope a consumer program for consuming 1 million records per
seconds. I have developed with java program. That is not consuming that
much efficiently. Your help is much appreciated.

Thanks,
PREETHKUMAR T


Kafka consumer Exception handling and offset management

2020-09-23 Thread Preethkumar Thirupathi
Hi Team,

Currently I'm implementing Spring boot @kafkalistener. I need to know that
what all are the exception that may raise, while try to consume the record
from kafka topic. How to commit the current offset after successfully
processed the record.In between that I have handle the exception.
Kindly advise the scenarios, what type of exception we can implement snd it
would be better to have an architectural diagram.

Thanks,
PREETHKUMAR T