Hi all:
I have a question about "Transaction". For example, KafkaSource code like
this:
try {
getChannelProcessor().processEventBatch(eventList);
consumer.commitOffsets();}
Hi all:
I have a question about "Transaction". For example, KafkaSource code like
this:
try {
getChannelProcessor().processEventBatch(eventList);
consumer.commitOffsets();}