我收到卡夫卡发来的消息。所以我打算写一个listener和"onMessage“。我想处理它并将其推送到solr
中。
所以我的问题更多的是架构,就像我整个职业生涯都在处理web应用程序一样,所以在大数据中如何部署spring kafka
listener,这样我就可以每秒处理数以千计的消息。
SpringBoot
应用程序,以便在tomcat容器中运行。发布于 2018-08-02 01:22:02
如果您对所有实例使用相同的组id,则会将不同的分区分配给不同的使用者(您的应用程序的实例)。
因此,请确保您在要消费的主题中指定了足够的分区。
https://stackoverflow.com/questions/51637352
复制相似问题