You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by mm...@apache.org on 2021/01/26 06:14:57 UTC
[pulsar-client-go] branch master updated (c24191b -> 58a327d)
This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git.
from c24191b Clearing message queues after seek requests (#419)
add 58a327d Issue #448 make state thread safe in consumer_partition and connection (#451)
No new revisions were added by this update.
Summary of changes:
go.mod | 1 +
go.sum | 11 ++++++----
pulsar/consumer_partition.go | 50 ++++++++++++++++++++++++++++---------------
pulsar/internal/connection.go | 41 ++++++++++++++++++++++-------------
pulsar/producer_partition.go | 36 +++++++++++++++++++++++--------
5 files changed, 94 insertions(+), 45 deletions(-)