Fix documentation for transactions to disable send timeout by default (…

…apache#10901)
yangl · Jun 23, 2021 · 6dd4eb0 · 6dd4eb0
1 parent 8b0b19e
commit 6dd4eb0
Show file tree

Hide file tree

Showing 5 changed files with 5 additions and 0 deletions.
diff --git 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
@@ -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
@@ -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
@@ -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
@@ -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