Kafka如何实现多线程消费

1.线程封闭，即为每个线程实例化一个KafkaConsumer对象

一个现成话对饮一个KafkaConsumer实例，我们可以称之为消费线程。一个消费线程可以消费一个或多个分区中的消息，所有消费线程隶属同一个消费者组。
2.消费者程序使用单或多线程获取消息，同时创建多个消费线程执行消息处理逻辑。
获取消息的线程可以是一个，也可以是多个，每个线程维护专属的KafkaConsumer实例，处理消息则由特定的线程池来做，从而实现消息获取与消息处理的真正解耦。