This is an automated email from the ASF dual-hosted git repository.
rxl pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git
The following commit(s) were added to refs/heads/master by this push:
new 13d4581 Removed SendTimeout from producer options (#136)
13d4581 is described below
commit 13d458191c6f2023b845f980baa5e9395ca4bac6
Author: Matteo Merli <[email protected]>
AuthorDate: Thu Dec 19 18:34:12 2019 -0800
Removed SendTimeout from producer options (#136)
---
perf/perf-producer.go | 1 -
pulsar/producer.go | 6 ------
2 files changed, 7 deletions(-)
diff --git a/perf/perf-producer.go b/perf/perf-producer.go
index 61454d0..035285b 100644
--- a/perf/perf-producer.go
+++ b/perf/perf-producer.go
@@ -86,7 +86,6 @@ func produce(produceArgs *ProduceArgs, stop <-chan struct{}) {
Topic: produceArgs.Topic,
MaxPendingMessages: produceArgs.ProducerQueueSize,
BatchingMaxPublishDelay: time.Millisecond *
time.Duration(produceArgs.BatchingTimeMillis),
- SendTimeout: 0,
})
if err != nil {
log.Fatal(err)
diff --git a/pulsar/producer.go b/pulsar/producer.go
index 3998d4b..cb024fa 100644
--- a/pulsar/producer.go
+++ b/pulsar/producer.go
@@ -63,12 +63,6 @@ type ProducerOptions struct {
// This properties will be visible in the topic stats
Properties map[string]string
- // SendTimeout set the send timeout (default: 30 seconds)
- // If a message is not acknowledged by the server before the
sendTimeout expires, an error will be reported.
- // Setting the timeout to -1, will set the timeout to infinity, which
can be useful when using Pulsar's message
- // duplication feature.
- SendTimeout time.Duration
-
// MaxPendingMessages set the max size of the queue holding the
messages pending to receive an acknowledgment from the broker.
MaxPendingMessages int
