flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aljos...@apache.org
Subject flink git commit: [hotfix][docs] Improve Kafka exactly-once docs
Date Thu, 23 Nov 2017 14:02:42 GMT
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.nowojski@gmail.com>
Authored: Thu Nov 23 13:08:43 2017 +0100
Committer: Aljoscha Krettek <aljoscha.krettek@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


Mime
View raw message