kafka_2.11-0.8.2.1 消费者再平衡

kafka_2.11-0.8.2.1 Consumer Rebalancing

我有一个包含 50 个分区的主题。我有一个消费者项目,它有 50 个线程处理 50 个消息流。截至目前,该项目仅在一个节点中 运行。我正在使用高级消费者。同一个项目是否可以部署在1个以上节点实现再平衡?有什么需要注意的问题吗?

是否可以将同一个项目部署在1个以上节点实现再平衡?

是的,您可以将消费者部署到多个节点以读取主题。

有什么需要注意的问题吗? 甚至在转到多个节点之前,您可以在同一节点上创建多个消费者来测试重新平衡以查看配置中出现的问题类型。 除此之外,如果一个或多个完成的节点死亡,您应该考虑重新平衡,然后其他节点应该处理。