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(-)
