kafka的消息是以key-value的形式存在的。
producer根据消息的key,决定这条消息最终被分配到哪个partition。
分配分区采用的是hash算法,在分区不变的情况下,同一个key总是分配到一个分区。
但是在分区增加或者减少的情况下,就没法保证同一个key总是分配到一个分区了。这个是在进行消息发送时需要考虑的问题。
kafka的消息是以key-value的形式存在的。
producer根据消息的key,决定这条消息最终被分配到哪个partition。
分配分区采用的是hash算法,在分区不变的情况下,同一个key总是分配到一个分区。
但是在分区增加或者减少的情况下,就没法保证同一个key总是分配到一个分区了。这个是在进行消息发送时需要考虑的问题。