This is an automated email from the ASF dual-hosted git repository.
eolivelli pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from b22d474 [fix][java-client] Fix message publishing stuck when enabling
batch (#14870)
add 2517649 [tests] Add Kinesis Sink integration tests (#14796)
No new revisions were added by this update.
Summary of changes:
pulsar-io/kinesis/pom.xml | 12 +
.../pulsar/io/kinesis/BaseKinesisConfig.java | 3 +-
.../org/apache/pulsar/io/kinesis/KinesisSink.java | 7 +
.../pulsar/io/kinesis/KinesisSinkConfig.java | 14 ++
...nesisSinkTest.java => KinesisSinkAuthTest.java} | 5 +-
.../apache/pulsar/io/kinesis/KinesisSinkTest.java | 243 +++++++++++----------
.../docker-images/latest-version-image/Dockerfile | 1 +
tests/integration/pom.xml | 19 ++
.../integration/io/sinks/KinesisSinkTester.java | 132 +++++++++++
.../integration/io/sinks/PulsarSinksTest.java | 5 +
.../tests/integration/io/sinks/SinkTester.java | 1 +
11 files changed, 322 insertions(+), 120 deletions(-)
copy
pulsar-io/kinesis/src/test/java/org/apache/pulsar/io/kinesis/{KinesisSinkTest.java
=> KinesisSinkAuthTest.java} (98%)
create mode 100644
tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sinks/KinesisSinkTester.java
