Repository: flink Updated Branches: refs/heads/master 7ff3f373a -> fda2c9ff6
[hotfix][docs] Improve Kafka exactly-once docs Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fda2c9ff Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fda2c9ff Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/fda2c9ff Branch: refs/heads/master Commit: fda2c9ff6080c4e776fb36b76d574bcd3777dd7b Parents: 7ff3f37 Author: Piotr Nowojski <piotr.nowoj...@gmail.com> Authored: Thu Nov 23 13:08:43 2017 +0100 Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com> Committed: Thu Nov 23 15:02:26 2017 +0100 ---------------------------------------------------------------------- docs/dev/connectors/kafka.md | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/fda2c9ff/docs/dev/connectors/kafka.md ---------------------------------------------------------------------- diff --git a/docs/dev/connectors/kafka.md b/docs/dev/connectors/kafka.md index ad4cc2f..5376d5b 100644 --- a/docs/dev/connectors/kafka.md +++ b/docs/dev/connectors/kafka.md @@ -538,7 +538,10 @@ chosen by passing appropriate `semantic` parameter to the `FlinkKafkaProducer011 be duplicated. * `Semantic.AT_LEAST_ONCE` (default setting): similar to `setFlushOnCheckpoint(true)` in `FlinkKafkaProducer010`. This guarantees that no records will be lost (although they can be duplicated). - * `Semantic.EXACTLY_ONCE`: uses Kafka transactions to provide exactly-once semantic. + * `Semantic.EXACTLY_ONCE`: uses Kafka transactions to provide exactly-once semantic. Whenever you write + to Kafka using transactions, do not forget about setting desired `isolation.level` (`read_committed` + or `read_uncommitted` - the latter one is the default value) for any application consuming records + from Kafka. <div class="alert alert-warning"> <strong>Attention:</strong> Depending on your Kafka configuration, even after Kafka acknowledges