java如何使用RMQ和spring cloud stream创建基于分区的生产者?
我试图找到SpringCloudStream的例子,它为RMQ创建了基于分区的生产者。我想看看它将如何为这些队列创建绑定,因为RMQ本机不支持主题的分区,但它将创建与分区数量相等的队列数量(我读了这篇文章,可能是错的)。首先,我想了解如何在RMQ上使用SpringCloudStream为基于分区的producer创建producer
你可以在下面搜索框中键入要查询的问题!
我试图找到SpringCloudStream的例子,它为RMQ创建了基于分区的生产者。我想看看它将如何为这些队列创建绑定,因为RMQ本机不支持主题的分区,但它将创建与分区数量相等的队列数量(我读了这篇文章,可能是错的)。首先,我想了解如何在RMQ上使用SpringCloudStream为基于分区的producer创建producer
# 1 楼答案
有房地产
我添加了
required-groups
,这样您就可以看到消费者队列是如何绑定的foo
呼气绑定:表达式可以是针对消息计算的任何有效表达式(例如
payload.hashCode()
);然后根据分区计数调整%
以确定最终分区