我收到Kafka的留言。所以我打算写一个聆听者和“onmessage”。我想处理它并把它推到 solr .所以我的问题更像是架构问题,就像我整个职业生涯都在做网络应用一样,那么在大数据领域如何部署spring kafka 侦听器,这样我可以每秒处理数千条消息。如何使spring代码使用多个节点来分配负载?我正打算写一本书 SpringBoot 应用程序在tomcat容器中运行。
solr
kafka
SpringBoot
7rtdyuoh1#
如果对所有示例使用相同的组id,则不同的分区将分配给不同的使用者(应用程序的示例)。因此,请确保在要使用的主题中指定了足够的分区。
1条答案
按热度按时间7rtdyuoh1#
如果对所有示例使用相同的组id,则不同的分区将分配给不同的使用者(应用程序的示例)。
因此,请确保在要使用的主题中指定了足够的分区。