This is an automated email from the ASF dual-hosted git repository. penghui pushed a commit to branch branch-2.8 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit c2d37079fa515e0eff60733647fba59ada79fd00 Author: xuesongxs <[email protected]> AuthorDate: Wed Jun 16 09:23:43 2021 +0800 Fix documentation for transactions to disable send timeout by default (#10901) (cherry picked from commit edc03c0bb6d4213beca74b429f2935904442af5e) --- site2/docs/transaction-api.md | 1 + site2/website/versioned_docs/version-2.7.0/transaction-api.md | 1 + site2/website/versioned_docs/version-2.7.1/transaction-api.md | 1 + site2/website/versioned_docs/version-2.7.2/transaction-api.md | 1 + site2/website/versioned_docs/version-2.7.3/transaction-api.md | 1 + 5 files changed, 5 insertions(+) diff --git a/site2/docs/transaction-api.md b/site2/docs/transaction-api.md index b615038..048eac1 100644 --- a/site2/docs/transaction-api.md +++ b/site2/docs/transaction-api.md @@ -106,6 +106,7 @@ Consumer<String> sourceConsumer = pulsarClient Producer<String> sinkProducer = pulsarClient .newProducer(Schema.STRING) .topic(sinkTopic) + .sendTimeout(0, TimeUnit.MILLISECONDS) .create(); Transaction txn = pulsarClient diff --git a/site2/website/versioned_docs/version-2.7.0/transaction-api.md b/site2/website/versioned_docs/version-2.7.0/transaction-api.md index 0eeea49..7d6a897 100644 --- a/site2/website/versioned_docs/version-2.7.0/transaction-api.md +++ b/site2/website/versioned_docs/version-2.7.0/transaction-api.md @@ -109,6 +109,7 @@ Consumer<String> sourceConsumer = pulsarClient Producer<String> sinkProducer = pulsarClient .newProducer(Schema.STRING) .topic(sinkTopic) + .sendTimeout(0, TimeUnit.MILLISECONDS) .create(); Transaction txn = pulsarClient diff --git a/site2/website/versioned_docs/version-2.7.1/transaction-api.md b/site2/website/versioned_docs/version-2.7.1/transaction-api.md index 45e46c8..630d3c2 100644 --- a/site2/website/versioned_docs/version-2.7.1/transaction-api.md +++ b/site2/website/versioned_docs/version-2.7.1/transaction-api.md @@ -109,6 +109,7 @@ Consumer<String> sourceConsumer = pulsarClient Producer<String> sinkProducer = pulsarClient .newProducer(Schema.STRING) .topic(sinkTopic) + .sendTimeout(0, TimeUnit.MILLISECONDS) .create(); Transaction txn = pulsarClient diff --git a/site2/website/versioned_docs/version-2.7.2/transaction-api.md b/site2/website/versioned_docs/version-2.7.2/transaction-api.md index 2fead1b..baeed78 100644 --- a/site2/website/versioned_docs/version-2.7.2/transaction-api.md +++ b/site2/website/versioned_docs/version-2.7.2/transaction-api.md @@ -109,6 +109,7 @@ Consumer<String> sourceConsumer = pulsarClient Producer<String> sinkProducer = pulsarClient .newProducer(Schema.STRING) .topic(sinkTopic) + .sendTimeout(0, TimeUnit.MILLISECONDS) .create(); Transaction txn = pulsarClient diff --git a/site2/website/versioned_docs/version-2.7.3/transaction-api.md b/site2/website/versioned_docs/version-2.7.3/transaction-api.md index 39b46a5..23c4509 100644 --- a/site2/website/versioned_docs/version-2.7.3/transaction-api.md +++ b/site2/website/versioned_docs/version-2.7.3/transaction-api.md @@ -109,6 +109,7 @@ Consumer<String> sourceConsumer = pulsarClient Producer<String> sinkProducer = pulsarClient .newProducer(Schema.STRING) .topic(sinkTopic) + .sendTimeout(0, TimeUnit.MILLISECONDS) .create(); Transaction txn = pulsarClient
