kafka中消费者如何保证幂等性?有没有唯一的messageId呢?

达尔文. 发表于: 2021-11-16   最后更新时间: 2021-11-16 16:15:43   1,842 游览

kafka消费者解决幂等性的话,有没有唯一的MessageId,比如RabbitMq中就有个唯一的MessageId就很方便消费者解决幂等性。

发表于 2021-11-16
添加评论

生产者发送消息的时候,可以设置"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消息传递保障

你的答案

查看kafka相关的其他问题或提一个您自己的问题