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 28e187436f4 [fix][broker]Fix never recovered metadata store bad
version issue if received a large response from ZK (#24580)
new 3ec5e640c5c [feat][fn] Fallback to using `STATE_STORAGE_SERVICE_URL`
in `PulsarMetadataStateStoreProviderImpl.init` (#24721)
new ba50b60c63a [fix][client] Avoid recycling the same
ConcurrentBitSetRecyclable among different threads (#24725)
new 9fc8dfb55d1 [fix][io] Improve Kafka Connect source offset flushing
logic (#24654)
The 3 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:
.../PersistentAcknowledgmentsGroupingTracker.java | 29 +--
.../impl/AcknowledgementsGroupingTrackerTest.java | 29 +--
.../PulsarMetadataStateStoreProviderImpl.java | 4 +
pulsar-io/kafka-connect-adaptor/pom.xml | 6 +
.../kafka/connect/AbstractKafkaConnectSource.java | 141 +++++++------
.../io/kafka/connect/KafkaConnectSourceTest.java | 186 ++++++++++++++++-
.../functions/PulsarBKStateStoreTest.java} | 8 +
.../functions/PulsarMetadataStateStoreTest.java | 60 ++++++
.../integration/functions/PulsarStateTest.java | 220 ++++++++++++---------
.../src/test/resources/pulsar-function.xml | 3 +-
10 files changed, 499 insertions(+), 187 deletions(-)
copy
tests/{docker-images/java-test-functions/src/main/java/org/apache/pulsar/tests/integration/functions/package-info.java
=>
integration/src/test/java/org/apache/pulsar/tests/integration/functions/PulsarBKStateStoreTest.java}
(77%)
create mode 100644
tests/integration/src/test/java/org/apache/pulsar/tests/integration/functions/PulsarMetadataStateStoreTest.java
