实际场景中的应用
代码如下:import lombok.extern.slf4j.Slf4j; import org.apache.kafka.clients.consumer.ConsumerRecord; import org.springframework.util.CollectionUtils; import java.util.List; @Slf4j public abstract class NppMultipleConsumer{ public void consume(List > consumerRecordList) { if (CollectionUtils.isEmpty(consumerRecordList)) { return; } String topicId = consumerRecordList.get(0).topic(); //1、批量解析消息对象;处理数据库之前的操作 Lis



