如何使Spring kafka客户端分布式

Question

我有来自 Kafka 的消息。所以我打算写一个监听器和"onMessage"。我想处理它并将其推送到 solr。

所以我的问题更具架构性，就像我整个职业生涯都在开发 Web 应用程序一样，所以在大数据中如何部署 spring kafka 侦听器，以便我可以处理数千条消息一秒钟。

1. 如何让我的 spring 代码使用多个节点来分发 加载？
2. 我打算在 运行 中写一份 SpringBoot 申请 一个 tomcat 容器。

Answer 1

如果您对所有实例使用相同的组 ID，则不同的分区将分配给不同的使用者（您的应用程序的实例）。

因此，请确保您在要使用的主题中指定了足够的分区。