You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by GitBox <gi...@apache.org> on 2019/01/18 14:20:39 UTC

[GitHub] alpinegizmo commented on a change in pull request #7260: [hotfix][docs] Fix typo and make improvement in Kafka Connectors doc

alpinegizmo commented on a change in pull request #7260: [hotfix][docs] Fix typo and make improvement in Kafka Connectors doc
URL: https://github.com/apache/flink/pull/7260#discussion_r249058476
 
 

 ##########
 File path: docs/dev/connectors/kafka.md
 ##########
 @@ -681,13 +681,13 @@ chosen by passing appropriate `semantic` parameter to the `FlinkKafkaProducer011
 
 `Semantic.EXACTLY_ONCE` mode relies on the ability to commit transactions
 that were started before taking a checkpoint, after recovering from the said checkpoint. If the time
-between Flink application crash and completed restart is larger then Kafka's transaction timeout
+between Flink application crash and completed restart is larger than Kafka's transaction timeout
 there will be data loss (Kafka will automatically abort transactions that exceeded timeout time).
 Having this in mind, please configure your transaction timeout appropriately to your expected down
 times.
 
 Kafka brokers by default have `transaction.max.timeout.ms` set to 15 minutes. This property will
-not allow to set transaction timeouts for the producers larger then it's value.
+not allow to set transaction timeouts for the producers larger than it's value.
 `FlinkKafkaProducer011` by default sets the `transaction.timeout.ms` property in producer config to
 
 Review comment:
   This paragraph needs additional help. I suggest:
   
   Kafka will not allow producers to set transactions timeouts greater than the value of `transaction.max.timeout.ms`, which by default is set to 15 minutes. As `FlinkKafkaProducer011` sets the `transaction.timeout.ms` property in the producer configuration to 1 hour, by default, you should increase `transaction.max.timeout.ms` before using
   `Semantic.EXACTLY_ONCE` mode.

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services