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 50da9b2 fix non-persistent topic get partitioned metadata error on
discovery (#10806)
new 9c3e904 fix parseMessageMetadata error cause by not skip broker entry
metadata (#10968)
new 1a2f820 [Security] Upgrade commons-codec to 1.15 (#10864)
new be1eedc [Security] Upgrade vertx to 3.9.8 to address CVE-2019-17640
(#10889)
new fc27d0e Change the nar package name for
pulsar-io-kafka-connect-adaptor (#10976)
new b7259cd fix NoClassDefFoundError - io.airlift.compress.lz4.UnsafeUtil
(#10983)
new d7bff1e Fix incorrect port of advertisedListener (#10961)
new c019c2a [Broker] Fix create partitioned topic in replicated namespace
(#10963)
new 72f3911 Fix potential data lost on the system topic when topic
compaction have not triggered yet (#11003)
new 83a29ec [Transaction] Fix broker init transaction related topic.
(#11022)
new a5e643c [Python] Fixed import when AvroSchema is not being used
(#11034)
new d23c5ed Made the PulsarClusterMetadataTeardown deletes idempotent
(#11042)
new 68889ef [C++] Fix Windows 32 bits compile and runtime failures
(#11082)
new 4cf7165 [Issue 11075] Use the subscription name defined in function
details (#11076)
The 13 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:
.github/workflows/ci-cpp-build-windows.yaml | 7 +
distribution/io/src/assemble/io.xml | 2 +-
distribution/server/src/assemble/LICENSE.bin.txt | 13 +-
pom.xml | 6 +-
.../pulsar/broker/ServiceConfigurationUtils.java | 8 +-
.../validator/MultipleListenerValidatorTest.java | 15 ++-
.../pulsar/PulsarClusterMetadataTeardown.java | 27 ++--
.../org/apache/pulsar/broker/PulsarService.java | 26 +++-
.../apache/pulsar/broker/admin/AdminResource.java | 120 +++++++++++------
.../broker/admin/impl/PersistentTopicsBase.java | 2 -
.../broker/admin/v1/NonPersistentTopics.java | 15 ++-
.../pulsar/broker/admin/v1/PersistentTopics.java | 15 ++-
.../broker/admin/v2/NonPersistentTopics.java | 6 +-
.../pulsar/broker/admin/v2/PersistentTopics.java | 5 +-
.../loadbalance/impl/ModularLoadManagerImpl.java | 2 +-
.../pulsar/broker/service/BrokerService.java | 11 +-
.../service/persistent/PersistentSubscription.java | 7 +-
.../broker/service/persistent/PersistentTopic.java | 20 +--
.../broker/service/persistent/SystemTopic.java | 21 ++-
.../apache/pulsar/compaction/CompactorTool.java | 8 +-
.../apache/pulsar/broker/PulsarServiceTest.java | 19 ++-
.../org/apache/pulsar/broker/admin/AdminTest.java | 2 +-
.../pulsar/broker/admin/PersistentTopicsTest.java | 27 ++--
.../pulsar/broker/admin/TopicPoliciesTest.java | 14 +-
.../broker/service/BrokerEntryMetadataE2ETest.java | 20 +++
.../pulsar/broker/service/ReplicatorTest.java | 62 ++++++++-
.../SystemTopicBasedTopicPoliciesServiceTest.java | 53 ++++----
.../pulsar/broker/transaction/TransactionTest.java | 142 +++++++++++++++++++++
.../pulsar/client/admin/internal/TopicsImpl.java | 8 +-
pulsar-client-cpp/README.md | 8 +-
pulsar-client-cpp/lib/CMakeLists.txt | 2 +-
pulsar-client-cpp/lib/checksum/crc32c_sse42.cc | 12 +-
pulsar-client-cpp/python/pulsar/schema/__init__.py | 3 +-
pulsar-client-cpp/python/pulsar/schema/schema.py | 27 ----
.../python/pulsar/schema/schema_avro.py | 67 ++++++++++
.../org/apache/pulsar/client/impl/MessageImpl.java | 2 -
.../apache/pulsar/client/impl/MessageImplTest.java | 51 ++++++++
.../apache/pulsar/common/protocol/Commands.java | 5 +-
.../instance/src/main/python/python_instance.py | 9 +-
pulsar-io/kafka-connect-adaptor-nar/pom.xml | 3 +
pulsar-sql/presto-distribution/LICENSE | 6 +-
.../cli/ClusterMetadataTearDownTest.java | 3 +
42 files changed, 675 insertions(+), 206 deletions(-)
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/transaction/TransactionTest.java
create mode 100644 pulsar-client-cpp/python/pulsar/schema/schema_avro.py
