有关kafka多线程启动多个Consumer报错的问题

谢谢 您的回复。我还有个问题我一次性订阅多个Topic，用一个线程去启动会有性能问题吗？

不会，一般拉取的数据要高于处理的速度。

您好！我现在遇到的情况是在使用多线程处理拉取的消息后，相对而言拉取消息的耗时远超过处理时间，这种情况可以从哪些方面进行改进呢？

new Thread(new Runnable() {
@Override
public void run() {
new ConsumerForward(consumerFactory.getConsumer(topicName)).poll(topicName, obj, transObj);
}
}, topicName + "-consumerThread").start();

博主，我下载的您写的客户端中，是不是启动一个新的线程去拉去数据？我在运行的时候也遇到这样的错误。

不用写新线程去拉取消息呀。
poll从这个里面才需要分发消息。