This is an automated email from the ASF dual-hosted git repository. sanjeevrk pushed a change to branch srkukarni/serverside_validation_endpoints in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 8fd2209 Logic correction add dd4f71d [clients][kafka] Fix topic name & race condition on kafka wrapper (#2746) add f718128 All grpc calls should have timeouts (#2747) add 90aa408 Fix getstatus logic in kubernetes runtime (#2748) new d7d178c Merge branch 'master' into serverside_validation_endpoints new 6915ff8 Fix bugs after mergin new a19d636 More compile fixes new 888867c Fixed path for sink 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: buildtools/src/main/resources/log4j2.xml | 1 + .../pulsar/broker/admin/impl/FunctionsBase.java | 2 +- .../apache/pulsar/broker/admin/impl/SinkBase.java | 2 +- .../pulsar/broker/admin/impl/SourceBase.java | 2 +- .../org/apache/pulsar/io/PulsarSinkE2ETest.java | 2 +- .../clients/consumer/PulsarKafkaConsumer.java | 37 +++-- .../src/main/proto/InstanceCommunication.proto | 1 + .../functions/runtime/KubernetesRuntime.java | 4 +- .../pulsar/functions/runtime/ProcessRuntime.java | 11 +- .../functions/worker/FunctionRuntimeManager.java | 41 +++++- .../functions/worker/rest/api/FunctionsImpl.java | 8 +- .../worker/rest/api/v2/FunctionApiV2Resource.java | 2 +- .../worker/rest/api/v2/SinkApiV2Resource.java | 4 +- .../worker/rest/api/v2/SourceApiV2Resource.java | 2 +- ...luster-2-bookie-1-broker-unstarted-with-s3.yaml | 164 --------------------- tests/integration/pom.xml | 11 ++ .../topologies/PulsarStandaloneTestBase.java | 1 - tests/pom.xml | 1 + .../pom.xml | 92 ++---------- .../integration/compat/kafka/KafkaApiTest.java | 83 ++++++----- 20 files changed, 161 insertions(+), 310 deletions(-) delete mode 100644 tests/integration-tests-topologies/src/main/resources/cube-definitions/single-cluster-2-bookie-1-broker-unstarted-with-s3.yaml copy tests/{integration => pulsar-kafka-compat-client-test}/pom.xml (58%) rename tests/{integration => pulsar-kafka-compat-client-test}/src/test/java/org/apache/pulsar/tests/integration/compat/kafka/KafkaApiTest.java (88%)