This is an automated email from the ASF dual-hosted git repository.
penghui pushed a change to branch branch-2.7
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from b4044cd Fix cherry-pick conflicts
new 3807b2e [BUG]fix zkBookieRackAffinityMapping bug to support for
bookkeeper dnsResolver (#9894)
new 5ce2e51 [Issue-9926][Pulsar Functions] Pass through record properties
from Pulsar Sources (#9943)
new 8247222 Allow to use KeyValue<GenericRecord, GenericRecord> (#9981)
new ff6b054 Fix the useless retry when the maximum number of
subscriptions is reached (#9991)
new 5340462 [C++] Fix segfault when get topic name from received message
id (#10006)
new e76e199 Fix check-style issue after cherry-pick
new 0daf3da Fix cherry-pick conflicts
The 7 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:
.../broker/service/persistent/PersistentTopic.java | 11 +-
.../pulsar/broker/admin/TopicPoliciesTest.java | 39 +++++
.../apache/pulsar/broker/service/KeyValueTest.java | 107 +++++++++++++
pulsar-client-cpp/lib/ConsumerImpl.cc | 1 +
pulsar-client-cpp/tests/ConsumerTest.cc | 52 +++++++
.../pulsar/client/impl/HttpLookupService.java | 21 ++-
.../pulsar/functions/utils/SourceConfigUtils.java | 2 +
.../zookeeper/ZkBookieRackAffinityMapping.java | 7 +-
.../tests/integration/io/TestPropertySource.java | 29 ++--
.../integration/io/PulsarSourcePropertyTest.java | 170 +++++++++++++++++++++
.../src/test/resources/pulsar-function-state.xml | 1 +
11 files changed, 421 insertions(+), 19 deletions(-)
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/KeyValueTest.java
copy
pulsar-io/data-generator/src/main/java/org/apache/pulsar/io/datagenerator/DataGeneratorSource.java
=>
tests/docker-images/java-test-functions/src/main/java/org/apache/pulsar/tests/integration/io/TestPropertySource.java
(68%)
create mode 100644
tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/PulsarSourcePropertyTest.java
