上杭网站建设国内新闻
kafka如何保证消息的有序
可以通过key-ording策略解决。kafka可以为每条消息定义消息键，也称为key，通常是带有业务属性的比如用户id之类的。有相同消息键的消息会被发到同一个分区。下面实现了key-ordering策略，对key的hashcode进行取模来决定发到哪个分区
List<PartitionInfo> partitions = cluster.partitionsForTopic(topic);
return Math.abs(key.hashCode()) % partitions.size();
kafka默认的分区策略，如果key有值就使用key-ordering策略，如果没有值就使用轮训策略。
在消息重试的时候，分区策略会重新再计算一次吗
不会的。消息重试只是简单地将消息重新发送到之前的分区
key-ordering策略的问题
如果某些key数据库很大，有数据倾斜的问题。