You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by al...@apache.org on 2017/11/23 14:02:42 UTC
flink git commit: [hotfix][docs] Improve Kafka exactly-once docs
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 <pi...@gmail.com>
Authored: Thu Nov 23 13:08:43 2017 +0100
Committer: Aljoscha Krettek <al...@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