网站建设需求分析表怎么写,wordpress+android,网站改版制作,制造一个app需要花费多少钱kafka如何保证消息的有序
可以通过key-ording策略解决。kafka可以为每条消息定义消息键#xff0c;也称为key#xff0c;通常是带有业务属性的比如用户id之类的。有相同消息键的消息会被发到同一个分区。下面实现了key-ordering策略#xff0c;对key的hashcode进行取模来决…kafka如何保证消息的有序
可以通过key-ording策略解决。kafka可以为每条消息定义消息键也称为key通常是带有业务属性的比如用户id之类的。有相同消息键的消息会被发到同一个分区。下面实现了key-ordering策略对key的hashcode进行取模来决定发到哪个分区
ListPartitionInfo partitions cluster.partitionsForTopic(topic);
return Math.abs(key.hashCode()) % partitions.size();kafka默认的分区策略如果key有值就使用key-ordering策略如果没有值就使用轮训策略。
在消息重试的时候分区策略会重新再计算一次吗
不会的。消息重试只是简单地将消息重新发送到之前的分区
key-ordering策略的问题
如果某些key数据库很大有数据倾斜的问题。
kafka怎么保证分区数据和生产者消息顺序一致
