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 d413f29 [Security] Upgrade commons-compress to 1.21 (#11345)
new 93f0e89 Add error log for schema admin operation (#11427)
new d4fd235 Remove duplicate check for replicationClusterSet (#11429)
new ab8e94d swap getTopicReference(topic).isPresent() with
serviceUnit.includes(topicName) to reduce calling getTopicReference (#11405)
new 9f88b8a Reduce the probability of cache inconsistencies (#11423)
new 9767a82 make KafkaSourceRecord ack() async to avoid deadlock (#11435)
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/broker/admin/impl/NamespacesBase.java | 9 ---
.../broker/admin/impl/SchemasResourceBase.java | 10 ++++
.../pulsar/broker/service/BrokerService.java | 2 +-
.../functions/worker/FunctionMetaDataManager.java | 33 +++++++++--
.../worker/FunctionMetaDataManagerTest.java | 67 ++++++++++++++++++++--
.../kafka/connect/AbstractKafkaConnectSource.java | 43 +++++++-------
.../io/kafka/connect/PulsarOffsetBackingStore.java | 3 +-
7 files changed, 123 insertions(+), 44 deletions(-)
