达尔文.
这家伙太懒，什么都没留下
这家伙太懒，什么都没留下
生产者发送消息的时候，可以设置"key"，如下：
producer.send(new ProducerRecord<String, String>("my-topic", key, "消息"));
消费者获取：
System.out.printf("offset = %d, key = %s, value = %s%n", record.offset(), record.key(), record.value());
这个"key"，是生产者定义的，一般默认是null，是否是你需要的？
也可读读这篇文章：kafka消息传递保障
