Kafka的消息key有啥特殊的?
今天看到一篇优质的kafka分享《Kafka 万亿级消息实践之资源组流量掉零故障排查分析 》,里面有个比较有意思的场景:producer在生产端的消息指定了key属性,在broker节点磁盘故障之后,某topic数据无法正常发送。不仔细深究,第一印象肯定会疑问,不是应该故障后转移吗?咋会一直受影响呢? 带着这个疑问我们先来看下kafka源码ProducerRecord.java类的注解对消息key的作用说明: A key/value pair to be sent to Kafka. This consists of a topic name to which the record is being sent, an