This is an automated email from the ASF dual-hosted git repository.
zike pushed a change to branch branch-0.12.0
in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git
from 0f0d5a86 Fix SIGSEGV with zstd compression enabled (#1164)
new 436188c9 [Producer] respect context cancellation in Flush (#1165)
new 68cd09a9 [Fix] Fix Bytes Schema (#1173)
new 6ce5421b [feat] Support partitioned topic reader (#1178)
new 9fdefe2b [Fix] Fix available permits in MessageReceived (#1181)
new a5f06793 [fix] Fix Infinite Loop in Reader's `HasNext` Function (#1182)
The 5 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
pulsar/client_impl.go | 24 +--
pulsar/consumer.go | 7 +
pulsar/consumer_impl.go | 47 +++++-
pulsar/consumer_partition.go | 83 +++++++++-
pulsar/consumer_test.go | 6 +-
.../pulsartracing/producer_interceptor_test.go | 4 +
pulsar/producer.go | 7 +-
pulsar/producer_impl.go | 6 +-
pulsar/producer_partition.go | 18 ++-
pulsar/producer_test.go | 24 +--
pulsar/reader.go | 2 +
pulsar/reader_impl.go | 112 ++++++--------
pulsar/reader_test.go | 170 +++++++++++++++++++--
pulsar/schema.go | 2 +
pulsar/schema_test.go | 64 ++++++++
pulsar/table_view_test.go | 7 +
16 files changed, 464 insertions(+), 119 deletions(-)
