This is an automated email from the ASF dual-hosted git repository.
penghui pushed a change to branch branch-2.8
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from ed771af [Cherry-pick] Pass client builder to debezium database
history (#12112)
new b85d06e Upgrade BK to 4.14.4 and Grpc to 1.42.1 (#13714)
new 5a491c4 Issue 12019 Fix flaky test
ManagedLedgerTest.testMaximumRolloverTime (#12030)
new a669b25 Getting rid of CVes brought in with aerospike (#13819)
new 444d2a3 Getting rid of CVEs in batch-data-generator (#13820)
new f2bfe92 Getitng rid of CVEs in InfluxDB connector (#13821)
new 7751597 Getting rid of CVEs in Solr connector (#13822)
new 76fac61 NPE when get isAllowAutoUploadSchema (#13831)
new ee4ac7f6 [C++] Fix hasMessageAvailable returns wrong value for last
message (#13883)
new d4bf415 Fix batch message ack does not decrease the unacked-msg
count. (#13383)
new 9601de1 [Broker] Fix read schema compatibility strategy priority
(#13938)
new 5d796e3 Fix cherry-pick issue
The 11 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:
conf/broker.conf | 8 +-
distribution/server/src/assemble/LICENSE.bin.txt | 94 +++++++--------
.../bookkeeper/mledger/impl/ManagedLedgerTest.java | 7 +-
pom.xml | 10 +-
.../apache/pulsar/broker/ServiceConfiguration.java | 11 +-
.../apache/pulsar/broker/admin/AdminResource.java | 15 +++
.../pulsar/broker/admin/impl/NamespacesBase.java | 14 +--
.../broker/admin/impl/SchemasResourceBase.java | 42 ++-----
.../pulsar/broker/service/AbstractTopic.java | 18 +--
.../org/apache/pulsar/broker/service/Consumer.java | 129 ++++++++++++++++++---
.../org/apache/pulsar/broker/service/Topic.java | 6 +
.../broker/admin/AdminApiSchemaAutoUpdateTest.java | 22 ++--
.../pulsar/broker/admin/AdminApiSchemaTest.java | 53 +++++++++
.../pulsar/broker/service/BatchMessageTest.java | 2 +-
.../BatchMessageWithBatchIndexLevelTest.java | 108 +++++++++++++++++
.../PersistentDispatcherFailoverConsumerTest.java | 79 ++++++-------
.../SchemaCompatibilityCheckTest.java | 6 +-
.../SchemaTypeCompatibilityCheckTest.java | 8 +-
.../pulsar/common/policies/data/Policies.java | 3 +-
.../policies/data/SchemaCompatibilityStrategy.java | 5 +-
pulsar-client-cpp/lib/ClientConnection.cc | 23 ++--
pulsar-client-cpp/lib/ClientConnection.h | 5 +-
pulsar-client-cpp/lib/ConsumerImpl.cc | 119 ++++++++++++-------
pulsar-client-cpp/lib/ConsumerImpl.h | 23 ++--
pulsar-client-cpp/lib/GetLastMessageIdResponse.h | 56 +++++++++
...kGroupingTrackerDisabled.cc => MessageIdUtil.h} | 31 ++---
pulsar-client-cpp/lib/ReaderImpl.cc | 6 +
pulsar-client-cpp/tests/MessageIdTest.cc | 22 ++++
pulsar-client-cpp/tests/ReaderTest.cc | 45 +++++++
pulsar-io/batch-data-generator/pom.xml | 6 +
pulsar-io/influxdb/pom.xml | 4 +-
pulsar-io/solr/pom.xml | 2 +-
pulsar-sql/presto-distribution/LICENSE | 24 ++--
33 files changed, 717 insertions(+), 289 deletions(-)
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BatchMessageWithBatchIndexLevelTest.java
create mode 100644 pulsar-client-cpp/lib/GetLastMessageIdResponse.h
copy pulsar-client-cpp/lib/{AckGroupingTrackerDisabled.cc => MessageIdUtil.h}
(57%)