回答情况：
提问时间：
问题标签：
env = StreamExecutionEnvironment.getExecutionEnvironment();
.setParallelism(1); // non-parallel source is only required for exactly-once
浏览 0修改于2018-05-16得票数 2
回答已采纳
objects
.setParallelism(1); // non-parallel source is only required for exactly-once
浏览 0提问于2018-05-16得票数 0
回答已采纳
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();.setParallelism(1); // non-parallel source is only required for exactly-once
浏览 0修改于2018-05-13得票数 3
回答已采纳
我们希望使用exactly-once语义将数据存储在Kafka中，以避免消息重复。
浏览 86提问于2021-07-27得票数 1
回答已采纳
streamExecutionEnvironment.setParallelism(2);
// set mode to exactly-once
浏览 3提问于2022-11-04得票数 0
<<WLS Kernel>> <> <> <1316515696340> <BEA-200030> <Bridge "NameOfBridge" is configured to work in "Exactly-once" mode, and it is actually working in "Exactly-once" mode.>
在查看了配置之后，唯一与此相关的数字是“事务超时”(Transaction)
浏览 5修改于2011-09-22得票数 1
回答已采纳
编辑，因为我不能期望数据库的幂等性，为了避免保存到数据库(Exactly-Once)中的重复，我是否可以编写特定于数据库的查询(upsert)来更新给定的记录&如果没有，可以插入吗？
浏览 1修改于2020-03-06得票数 1
当涉及到exactly-once/transactions/idempotence.时，我能够找到所有关于Kafka Streams应用程序的融合文档 然而，事务的API是在“常规的”生产者/消费者级别上引入的
浏览 22修改于2020-12-18得票数 0
这种行为正常吗(我不这么认为)消费者和生产者设置是默认的，消息传递是"exactly-once".The代码，在本地设置和AWS上都会进行测试。
浏览 5提问于2022-01-22得票数 0
Read events", // this is to achieve exactly-once
浏览 1修改于2018-09-20得票数 2
true))
env.enableCheckpointing(1000)
// set mode to exactly-once
浏览 2提问于2019-05-05得票数 0
回答已采纳
true))
env.enableCheckpointing(1000)
// set mode to exactly-once
浏览 25修改于2019-04-15得票数 1
回答已采纳
are discarded env.getCheckpointConfig().setCheckpointTimeout(5000);
// set mode to exactly-once
浏览 1修改于2020-10-27得票数 0
回答已采纳
.
env.getCheckpointConfig().setCheckpointingMode
浏览 7修改于2020-03-21得票数 1
factory.setBatchErrorHandler(new FixedBackoffSeekToCurrentBatchErrorHandler());
//Enable transactional consumer for exactly-once
浏览 9修改于2022-04-26得票数 1
name: <link-name>,reliability: unreliable | at-most-once | at-least-once | exactly-once
浏览 10修改于2016-06-12得票数 1
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号