This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a change to branch branch-2.8
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from aa09ac4 Fix the batch message ack for WebSocket proxy. (#12530)
new 98a5bca Fixed used after recycle issue in OpAddEntry (#12103)
new c36b9d0 [C++] Fixed connection read error logging (#12492)
new 04e8d7e [Broker] Fix messageDedup delete inactive producer name
(#12493)
new 1fc1830 Update Producer stats on producer close() (#12500)
new c1e7f94 [Python Client] Python client support using custom Avro
schema definition (#12516)
new 27e121f Websocket should pass the encryption context to the consumers
(#12539)
The 6 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:
.../apache/bookkeeper/mledger/impl/OpAddEntry.java | 13 ++-
.../service/persistent/MessageDeduplication.java | 2 +
.../service/persistent/MessageDuplicationTest.java | 66 +++++++++++
.../websocket/proxy/ProxyPublishConsumeTest.java | 62 ++++++++++
.../websocket/proxy/SimpleConsumerSocket.java | 3 +
pulsar-client-cpp/lib/ClientConnection.cc | 4 +-
pulsar-client-cpp/python/examples/company.avsc | 19 +++
.../python/pulsar/schema/schema_avro.py | 29 +++--
pulsar-client-cpp/python/schema_test.py | 128 ++++++++++++++++++++-
.../client/impl/ProducerStatsRecorderImpl.java | 90 ++++++++-------
.../client/impl/PartitionedProducerImplTest.java | 33 ++++++
.../client/impl/ProducerStatsRecorderImplTest.java | 20 ++++
.../apache/pulsar/websocket/ConsumerHandler.java | 1 +
.../pulsar/websocket/data/ConsumerMessage.java | 3 +
14 files changed, 408 insertions(+), 65 deletions(-)
create mode 100644 pulsar-client-cpp/python/examples/company.avsc
