kafka发送消息分区选择策略详解 | 戒修
背景面试被问到kafka消息发送是分区选择的策略,当时回答说是随机选择一个分区;或者通过消息key的hash值和分区数计算出分区。当时只是猜测的,并没有查看过kafka的源代码来证实,今天就通过源码来证实一下。 发送消息的一个简单例子12345678910111213141516171819 private static void sendMsg() { String topicName = "kafka-test"; // 设置配置属性 Properties props = new Properties(); props.put("metadata.broker.list", "127.0.0.1:2181"); props.put("bootstrap.servers", "127.0....阅读全文