This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a change to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from abb3c8435d3 [fix][broker] Fix ByteBuf memory leak in REST API for
publishing messages (#24228)
new fb863a4150f [fix][broker] Orphan schema after disabled a cluster for a
namespace (#24223)
new 2596edc1277 [improve][client]Improve transaction log when a TXN
command timeout (#24230)
new fc26945ffc0 [improve][io] support kafka connect transforms and
predicates (#24221)
new 1ac0898a0f9 [fix][sec] Upgrade Jetty to 9.4.57.v20241219 to mitigate
CVE-2024-6763 (#24232)
The 4 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:
distribution/server/src/assemble/LICENSE.bin.txt | 38 +++----
distribution/shell/src/assemble/LICENSE.bin.txt | 16 +--
pom.xml | 2 +-
.../broker/service/persistent/PersistentTopic.java | 54 ++++++++-
...OneWayReplicatorUsingGlobalPartitionedTest.java | 45 ++++++--
.../client/impl/TransactionMetaStoreHandler.java | 44 ++++++--
pulsar-io/kafka-connect-adaptor/pom.xml | 12 ++
.../kafka/connect/AbstractKafkaConnectSource.java | 2 +-
.../io/kafka/connect/KafkaConnectSource.java | 121 ++++++++++++++++++++-
.../io/kafka/connect/KafkaConnectSourceTest.java | 71 ++++++++++++
10 files changed, 358 insertions(+), 47 deletions(-)
