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%)
