问flink如何保证卡夫卡唱片在重试后准确地保存一次？
EN

Stack Overflow用户

提问于 2020-05-06 07:49:45

回答 2查看 252关注 0票数 0

我的资料来源和接收器都是卡夫卡的主题。是否有一种方法可以为每个不同的卡夫卡记录生成一个独特的id精确一次？精确一次意味着如果发生重试，相同的记录仍然使用以前生成的id，接收器只存在单个记录。

发布于 2020-05-06 17:05:23

想到的最简单的想法就是简单地创建一个函数，为每条记录生成唯一的hashcode()作为long。如果哈希代码是基于字段的，那么对于非不同的记录，它将是相同的，对于不同的记录，它应该是不同的。

您甚至可以考虑在Java中使用来自hashcode()的Object。

票数 0

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/61629980

复制

相似问题

问flink如何保证卡夫卡唱片在重试后准确地保存一次？EN