kafka消费者解决幂等性的话,有没有唯一的MessageId,比如RabbitMq中就有个唯一的MessageId就很方便消费者解决幂等性。
生产者发送消息的时候,可以设置"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,是否是你需要的?
null
也可读读这篇文章:kafka消息传递保障
找不到想要的答案?提一个您自己的问题。
0 声望
这家伙太懒,什么都没留下
生产者发送消息的时候,可以设置"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消息传递保障
你的答案