This is an automated email from the ASF dual-hosted git repository.
guangning pushed a change to branch branch-2.5
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
discard 8fcbf43 Fix cherry-pick error (#6703)
omit a8068c8 Not allow sub auto create by admin when disable topic auto
create (#6685)
omit 15eb061 Amend the default value of . (#6374)
omit 5760800 Update README.md To Represent JDK 11 in Build Pulsar Doc
(#6686)
omit ebacb7e Release 2.5.1
omit 8d97134 Move 2.6.0-SNAPSHOT to 2.5.1
omit 40e9c5e Improve Key_Shared subscription message dispatching
performance. (#6647)
omit 0d16f77 Fixed avro schema decode error in functions (#6662)
omit 0a8243e Support BouncyCastle FIPS provider (#6588)
omit e82ef7a resume servercnx method to public (#6581)
omit 4cdd4de Fix NPE while call getLastMessageId. (#6562)
omit b66f11c Fix: topic with one partition cannot be updated (#6560)
omit a458fce Don't increment unacked messages for the consumer with
Exclusive/Failover subscription mode. (#6558)
omit 166498b Disable channel auto read when publish rate or publish buffer
exceeded (#6550)
omit e310de3 [Maven Cleanup] Remove managed-ledger and zk-utils test-jar
dependencies when possible (#6513)
omit 921e5f8 Fix admin getLastMessageId return batchIndex (#6511)
omit c735e13 Instead of always using admin access for topic, use
read/write/admin access for topic (#6504)
omit c0c5880 Start namespace service and schema registry service before
start broker. (#6499)
omit 5076755 [pulsar-client-cpp] Fix Redelivery of Messages on
UnackedMessageTracker When Ack Messages . (#6498)
omit 10e3499 [broker] Timeout API calls in BrokerService (#6489)
omit 79b8259 [pulsar-client] fix deadlock on send failure (#6488)
omit fb32d85 [proxy] Fix proxy routing to functions worker (#6486)
omit d618dcb Fix memory leak when running topic compaction. (#6485)
omit c23ab86 Fix some async method problems at PersistentTopicsBase.
(#6483)
omit 7c76082 Avoid calling ConsumerImpl::redeliverMessages() when message
list is empty (#6480)
omit 1c19557 Fix create partitioned topic with a substring of an existing
topic name. (#6478)
omit 98a57df [pulsar-proxy] fix logging for published messages (#6474)
omit 3683f30 pulsar-proxy: fix correct name for proxy thread executor name
(#6460)
omit 5138b4a Improve cpp-client-lib: provide another `libpulsarwithdeps.a`
in dep/rpm (#6458)
omit 546e1fe [Broker] Create namespace failed when TLS is enabled in
PulsarStandalone (#6457)
omit 49de49f Use System.nanoTime() instead of System.currentTimeMillis()
(#6454)
omit eb3a481 Fixed the max backoff configuration for lookups (#6444)
omit c412275 fix the bug of authenticationData is't initialized. (#6440)
omit ae741cf [Flink-Connector]Get PulsarClient from cache should always
return an open instance (#6436)
omit 9834056 Fix publish buffer limit does not take effect
omit 45f1272 Bump netty version to 4.1.45.Final (#6424)
omit ecbe886 Update BatchReceivePolicy.java (#6423)
omit a57861f [Java client] MultiTopics discovery is broken due to
discovery task scheduled twice instead of pendingBatchRecei… (#6407)
omit 3c9a442 [Issue 3762][Schema] Fix the problem with parsing of an Avro
schema related to shading in pulsar-client. (#6406)
omit 4ca6ab1 Add verification for SchemaDefinitionBuilderImpl.java (#6405)
omit 5db1329 Consumer received duplicated deplayed messages upon restart
omit 81c3244 Fixed enum package not found (#6401)
omit 211d7f0 Close ZK before canceling future with exception (#6228)
(#6399)
omit 1061ac8 [Minor] Fix java code errors reported by lgtm. (#6398)
omit 9bce472 Seek to the first one >= timestamp (#6393)
omit 3ba9728 [Reader] Should set either start message id or start message
from roll back duration. (#6392)
omit 8fe10ba [Issue 6168] Fix Unacked Message Tracker by Using Time
Partition on C++ (#6391)
omit ccc8e69 fix duplicate key to send propertys (#6390)
omit d2a20dd [Pulsar-Client] Stop shade snappy-java in
pulsar-client-shaded (#6375)
omit 151b762 [Issue 6355][HELM] autorecovery - could not find or load main
class (#6373)
omit 4cee828 Creating a topic does not wait for creating cursor of
replicators (#6364)
omit 37da6ce [ClientAPI]Fix hasMessageAvailable() (#6362)
omit 12a5dd5 remove future.join() from PulsarSinkEffectivelyOnceProcessor
(#6361)
omit 7ff6b8b Independent schema is set for each consumer generated by
topic (#6356)
omit 6af87b6 Fix broker to specify a list of bookie groups. (#6349)
omit 0002a25 [Java Reader Client] Start reader inside batch result in read
first message in batch. (#6345)
omit e939f55 Fix java doc for key shared policy. (#6341)
omit a67adb4 explicit statement env 'BOOKIE_MEM' and 'BOOKIE_GC' for
values-mini.yaml (#6340)
omit 0abaaee Avoid get partition metadata while the topic name is a
partition name. (#6339)
omit 55dd789 client: make SubscriptionMode a member of
ConsumerConfigurationData (#6337)
omit dffe575 Windows CMake corrections (#6336)
omit 3868669 Upgrade ZooKeeper to 3.5.7 (#6329)
omit 3790518 Should flush the last potential duplicated since can't
combine potential duplicated messages and non-duplicated messages into a batch.
(#6326)
omit afe1aa3 KeyValue schema support for pulsar sql (#6325)
omit a344229 Fixed casting in ZooKeeperCache.getDataIfPresent() (#6313)
omit 3329f42 Enable get precise backlog and backlog without delayed
messages. (#6310)
omit a93efc6 Remove problematic semicolon from conf (#6303)
omit 03f6286 [Issue 4070][pulsar-client-cpp] Fix for possible deadlock
when closing Pulsar client (#6277)
omit 59965cb Fix bug that tenants whose allowed clusters include global
cannot be created/updated (#6275)
omit 55b1254 [C++] Fixed handling of canceled timer events on
NegativeAcksTracker (#6272)
omit fafb6fa [C++] Fixed memory corruption on ExecutorService destructor
(#6270)
omit 274b67e Make tests more stable by using JSONAssert equals (#6247)
omit ba60a3f Fix deploy of WindowFunctions (#6246)
omit 4f1bedc [Issue 6173][compaction] Fix log compaction for flow
control/empty topic/last deletion (#6237)
omit bd439b3 Use fully qualified hostname as default to advertise brokers
(#6235)
omit bb3f0bb [authentication] Validate tokens for binary connections
(#6233)
omit 31e8e59 Fix bug that backlog message that has not yet expired could
be deleted due to TTL (#6211)
omit a89bd2d [functions] Default functionAuthProvider when running in k8s
(#6203)
omit c40ccf8 [ISSUE-6131]: Ensure JVM memory and GC options are set for
bookie (#6201)
omit 4f3f5f8 Pin the netty-transport-native-epoll to avoid conflicts
(#6194)
omit 4324c5b Fix get schema version in HttpLookupService. (#6193)
omit 4c86357 [deployement] make kubernetes yamls for aws operational
(#6192)
omit 4c19484 Corrected the method name for source implementation (#6190)
omit c6d59d9 Create managed ledger path on local zookeeper when create
partitions (#6189)
omit e33238f [Issue 5904]Support `unload` all partitions of a partitioned
topic (#6187)
omit 88dda60 Namespace level offloader (#6183)
omit b535ac4 Introduce maxMessagePublishBufferSizeInMB configuration to
avoid broker OOM (#6178)
omit 1736aa1 Supports evenly distribute topics count when splits bundle
(#6241)
omit 2d9e063 Restore clusterDispatchRate policy for compatibility (#6176)
omit 850ede6 add missing check to dashboard-ingress (helm chart) (#6160)
omit a9df727 [Issue-5994]: Start proxy pods when at least one broker pod
is running (#6158)
omit 077bd71 Output resource usage rate to log on broker (#6152)
omit 7c13b40 Fix broker client tls settings error (#6128)
omit ea134ff Add timeout to search for web service URLs to avoid web
threads getting stuck (#6124)
omit 2672574 [pulsar-admin] allow tenant admin to manage subscription
permission (#6122)
omit 4c3112a [Broker]Reset cursor with a non-exists position (#6120)
omit 13fd6b3 Fix zeroQueueConsumer using listener (#6106)
omit a2c3858 [Websocket] Websocket doesn't set the correct cluster data
(#6102)
omit e32173e [Functions] The argument and description for dead letter
topic is wrong (#6101)
omit 693b59d Fix message redelivery for zero queue consumer while using
async api to receive messages (#6090)
omit d7aa4d7 Add a message on how to make log refresh immediately when
starting a component (#6078)
omit 196aa81 Support delete inactive topic when subscriptions caught up
(#6077)
omit 46a1b28 Fix zero queue consumer message redelivery (#6076)
omit 5680a81 PIP-55: Refresh Authentication Credentials (#6074)
omit 4fbdc95 make acker transient (#6064)
omit ffa0b04 Fix issue 5505 (#6060)
omit 08ef06d Expose lastConsumedTimestamp and lastAckedTimestamp to
consumer stats (#6051)
omit f3ca73f Fix unit test (#6006)
omit 6be3149 [pulsar-broker] Clean up closed producer to avoid
publish-time for producer (#5988)
omit d662a4a Prevent creation of regular topic with the same name as
existing partitioned topic (#5943)
omit 0729333 Avoid using same OpAddEntry between different ledger handles
(#5942)
omit 31fcb38 Upgrade Avro to 1.9.1 (#5938)
omit 63a66d0 Fix negative un-ack messages in consumer stats (#5929)
omit e3877d8 Allow to enable/disable delayed delivery for messages on
namespace (#5915)
omit 33b2e24 add_backlogSize_in_topicStat (#5914)
omit 0f44118 [build] Skip javadoc task for pulsar-client-kafka-compact
modules (#5836)
omit f98d4c1 Expose bookkeeper expose explicit lac in broker.conf (#5822)
omit 2074c7b [pulsar-broker] close managed-ledgers before giving up bundle
ownership to avoid bad zk-version (#5599)
omit 2efd47d Fixed static linking on C++ lib on MacOS (#5581)
omit 80ad05f Fix create consumer on partitioned topic while disable topic
auto creation. (#5572)
new 0aa5b64 Fix create consumer on partitioned topic while disable topic
auto creation. (#5572)
new c69259a Fixed static linking on C++ lib on MacOS (#5581)
new f95aebb [pulsar-broker] close managed-ledgers before giving up bundle
ownership to avoid bad zk-version (#5599)
new c421d26 Expose bookkeeper expose explicit lac in broker.conf (#5822)
new eff08dd [build] Skip javadoc task for pulsar-client-kafka-compact
modules (#5836)
new 5d30766 add_backlogSize_in_topicStat (#5914)
new 9c68641 Allow to enable/disable delayed delivery for messages on
namespace (#5915)
new e413d41 Fix negative un-ack messages in consumer stats (#5929)
new 577eb1d Upgrade Avro to 1.9.1 (#5938)
new fed81a5 Avoid using same OpAddEntry between different ledger handles
(#5942)
new d4346ac Prevent creation of regular topic with the same name as
existing partitioned topic (#5943)
new 1b74759 [pulsar-broker] Clean up closed producer to avoid
publish-time for producer (#5988)
new 07006d5 Fix unit test (#6006)
new 06a72c0 Expose lastConsumedTimestamp and lastAckedTimestamp to
consumer stats (#6051)
new 4dd9ca8 Fix issue 5505 (#6060)
new 3b8bcb7 make acker transient (#6064)
new 32164db PIP-55: Refresh Authentication Credentials (#6074)
new 5ecbdb7 Fix zero queue consumer message redelivery (#6076)
new 03a1fc7 Support delete inactive topic when subscriptions caught up
(#6077)
new 478f905 Add a message on how to make log refresh immediately when
starting a component (#6078)
new de45930 Fix message redelivery for zero queue consumer while using
async api to receive messages (#6090)
new acdd987 [Functions] The argument and description for dead letter
topic is wrong (#6101)
new 13b65f1 [Websocket] Websocket doesn't set the correct cluster data
(#6102)
new fc51a13 Fix zeroQueueConsumer using listener (#6106)
new b40b7f5 [Broker]Reset cursor with a non-exists position (#6120)
new 8704d6a [pulsar-admin] allow tenant admin to manage subscription
permission (#6122)
new 5c76eb4 Add timeout to search for web service URLs to avoid web
threads getting stuck (#6124)
new 942e340 Fix broker client tls settings error (#6128)
new ef7e99b Output resource usage rate to log on broker (#6152)
new 0d50cf9 [Issue-5994]: Start proxy pods when at least one broker pod
is running (#6158)
new 5b60186 add missing check to dashboard-ingress (helm chart) (#6160)
new 3d5b926 Restore clusterDispatchRate policy for compatibility (#6176)
new 934002c Supports evenly distribute topics count when splits bundle
(#6241)
new a6dbbb9 Introduce maxMessagePublishBufferSizeInMB configuration to
avoid broker OOM (#6178)
new a64559d Namespace level offloader (#6183)
new 0f5a3ea [Issue 5904]Support `unload` all partitions of a partitioned
topic (#6187)
new 7656b1f Create managed ledger path on local zookeeper when create
partitions (#6189)
new ee92dde Corrected the method name for source implementation (#6190)
new a0c4422 [deployement] make kubernetes yamls for aws operational
(#6192)
new d285fc0 Fix get schema version in HttpLookupService. (#6193)
new 9b2ee74 Pin the netty-transport-native-epoll to avoid conflicts
(#6194)
new f0c2ce1 [ISSUE-6131]: Ensure JVM memory and GC options are set for
bookie (#6201)
new 9fc05c5 [functions] Default functionAuthProvider when running in k8s
(#6203)
new a49737d Fix bug that backlog message that has not yet expired could
be deleted due to TTL (#6211)
new a76cf23 [authentication] Validate tokens for binary connections
(#6233)
new b696d66 Use fully qualified hostname as default to advertise brokers
(#6235)
new 1f609ae [Issue 6173][compaction] Fix log compaction for flow
control/empty topic/last deletion (#6237)
new 731211c Fix deploy of WindowFunctions (#6246)
new 664470c Make tests more stable by using JSONAssert equals (#6247)
new 36b4734 [C++] Fixed memory corruption on ExecutorService destructor
(#6270)
new a183a87 [C++] Fixed handling of canceled timer events on
NegativeAcksTracker (#6272)
new 38c61af Fix bug that tenants whose allowed clusters include global
cannot be created/updated (#6275)
new cc8e38f [Issue 4070][pulsar-client-cpp] Fix for possible deadlock
when closing Pulsar client (#6277)
new 7bb708f Remove problematic semicolon from conf (#6303)
new ccef8ca Enable get precise backlog and backlog without delayed
messages. (#6310)
new 62081ab Fixed casting in ZooKeeperCache.getDataIfPresent() (#6313)
new 432135e KeyValue schema support for pulsar sql (#6325)
new 0f140e2 Should flush the last potential duplicated since can't
combine potential duplicated messages and non-duplicated messages into a batch.
(#6326)
new ebb1c6f Upgrade ZooKeeper to 3.5.7 (#6329)
new ea2cfad Windows CMake corrections (#6336)
new 2ccea55 client: make SubscriptionMode a member of
ConsumerConfigurationData (#6337)
new 4f4d0d2 Avoid get partition metadata while the topic name is a
partition name. (#6339)
new 29a4733 explicit statement env 'BOOKIE_MEM' and 'BOOKIE_GC' for
values-mini.yaml (#6340)
new 1b6266b Fix java doc for key shared policy. (#6341)
new d789b10 [Java Reader Client] Start reader inside batch result in read
first message in batch. (#6345)
new b908316 Fix broker to specify a list of bookie groups. (#6349)
new 13f898e Independent schema is set for each consumer generated by
topic (#6356)
new 8a11030 remove future.join() from PulsarSinkEffectivelyOnceProcessor
(#6361)
new 49207d7 [ClientAPI]Fix hasMessageAvailable() (#6362)
new d7b559e Creating a topic does not wait for creating cursor of
replicators (#6364)
new b5d0ac7 [Issue 6355][HELM] autorecovery - could not find or load main
class (#6373)
new 1ae7bd0 Amend the default value of . (#6374)
new 29a05c0 [Pulsar-Client] Stop shade snappy-java in
pulsar-client-shaded (#6375)
new 383b025 fix duplicate key to send propertys (#6390)
new 2cdbb1f [Issue 6168] Fix Unacked Message Tracker by Using Time
Partition on C++ (#6391)
new fbc54b4 [Reader] Should set either start message id or start message
from roll back duration. (#6392)
new 47148cf Seek to the first one >= timestamp (#6393)
new 6181612 [Minor] Fix java code errors reported by lgtm. (#6398)
new c41498e Close ZK before canceling future with exception (#6228)
(#6399)
new 9a8621f Fixed enum package not found (#6401)
new 63464ab Consumer received duplicated deplayed messages upon restart
new 81f4460 Add verification for SchemaDefinitionBuilderImpl.java (#6405)
new 337cdc5 [Issue 3762][Schema] Fix the problem with parsing of an Avro
schema related to shading in pulsar-client. (#6406)
new d98a092 [Java client] MultiTopics discovery is broken due to
discovery task scheduled twice instead of pendingBatchRecei… (#6407)
new 8db1e53 Update BatchReceivePolicy.java (#6423)
new 9488c6d Bump netty version to 4.1.45.Final (#6424)
new fd88321 Remove duplicated test libraries in POM dependencies (#6430)
new f59cd72 Fix publish buffer limit does not take effect
new 35a77b1 [Flink-Connector]Get PulsarClient from cache should always
return an open instance (#6436)
new 0e7d38a fix the bug of authenticationData is't initialized. (#6440)
new e8b93d5 Fixed the max backoff configuration for lookups (#6444)
new f6db479 Use System.nanoTime() instead of System.currentTimeMillis()
(#6454)
new 64ff3e1 [Broker] Create namespace failed when TLS is enabled in
PulsarStandalone (#6457)
new 48c3f42 Improve cpp-client-lib: provide another `libpulsarwithdeps.a`
in dep/rpm (#6458)
new ee784ae pulsar-proxy: fix correct name for proxy thread executor name
(#6460)
new 1d23d56 [pulsar-proxy] fix logging for published messages (#6474)
new 8f9749d Fix create partitioned topic with a substring of an existing
topic name. (#6478)
new 7d7d071 Avoid calling ConsumerImpl::redeliverMessages() when message
list is empty (#6480)
new 80e1475 Fix some async method problems at PersistentTopicsBase.
(#6483)
new 07ba135 Fix memory leak when running topic compaction. (#6485)
new 44ed37a [proxy] Fix proxy routing to functions worker (#6486)
new 7eeb10d [pulsar-client] fix deadlock on send failure (#6488)
new 9b10c94 [broker] Timeout API calls in BrokerService (#6489)
new 319eabb [pulsar-client] remove duplicate cnx method (#6490)
new 70337c7 [pulsar-client-cpp] Fix Redelivery of Messages on
UnackedMessageTracker When Ack Messages . (#6498)
new 45e8963 Start namespace service and schema registry service before
start broker. (#6499)
new 04c605f Instead of always using admin access for topic, use
read/write/admin access for topic (#6504)
new 8152d9d Fix admin getLastMessageId return batchIndex (#6511)
new 580b319 [Maven Cleanup] Remove managed-ledger and zk-utils test-jar
dependencies when possible (#6513)
new 5db8596 Disable channel auto read when publish rate or publish buffer
exceeded (#6550)
new 7bf3d6b Don't increment unacked messages for the consumer with
Exclusive/Failover subscription mode. (#6558)
new 9f33ee1 Fix: topic with one partition cannot be updated (#6560)
new 584079e Fix NPE while call getLastMessageId. (#6562)
new 5ff552a Do not retry on authorization failure (#6577)
new 37d9005 resume servercnx method to public (#6581)
new de57ddd Support BouncyCastle FIPS provider (#6588)
new 6119ccf Improve Key_Shared subscription message dispatching
performance. (#6647)
new 3f4c0e3 Fix send get raw schema request (#6650)
new d60eebf Fixed avro schema decode error in functions (#6662)
new 0319552 Handle KeeperException.BadVersionException thrown by
updateSchemaLocator() (#6683)
new 160cc50 Not allow sub auto create by admin when disable topic auto
create (#6685)
new 3a02f76 Update README.md To Represent JDK 11 in Build Pulsar Doc
(#6686)
new be7193e Improve backlogSize stats in the topic. (#6700)
new b234eff [pulsar-io-rabbitmq] Added integration test for RabbitMQ.
(#6033)
new 56b92d1 Add Joda time logical type conversion. (#6704)
new 4b233f9 Move 2.6.0-SNAPSHOT to 2.5.1
new c2dc1bd Fixed cherry-pick erro
new 7ff1673 Creating a topic does not wait for creating cursor of
replicators (#6364)
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (8fcbf43)
\
N -- N -- N refs/heads/branch-2.5 (7ff1673)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 128 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:
.github/workflows/ci-integration-process.yaml | 21 ++++
.github/workflows/ci-integration-thread.yaml | 21 ++++
.github/workflows/ci-unit-broker.yml | 17 ++-
.github/workflows/ci-unit.yaml | 13 +++
managed-ledger/pom.xml | 12 --
.../bookkeeper/mledger/impl/ManagedLedgerImpl.java | 8 +-
protobuf-shaded/pom.xml | 2 +-
pulsar-broker/pom.xml | 7 --
.../service/schema/BookkeeperSchemaStorage.java | 24 +++-
.../apache/pulsar/broker/admin/AdminApiTest.java | 27 +++++
.../apache/pulsar/client/api/ClientErrorsTest.java | 10 +-
.../pulsar/client/api/ProducerCreationTest.java | 2 +-
.../websocket/proxy/ProxyPublishConsumeTest.java | 4 +-
.../pulsar/client/api/PulsarClientException.java | 19 +++
.../pulsar/client/api/schema/SchemaDefinition.java | 7 ++
.../client/api/schema/SchemaDefinitionBuilder.java | 16 +++
pulsar-client-messagecrypto-bc/pom.xml | 1 -
pulsar-client-tools-test/pom.xml | 11 --
pulsar-client/pom.xml | 6 +
.../org/apache/pulsar/client/impl/ClientCnx.java | 2 +-
.../pulsar/client/impl/ConnectionHandler.java | 10 +-
.../apache/pulsar/client/impl/ConsumerImpl.java | 4 +-
.../apache/pulsar/client/impl/ProducerImpl.java | 12 +-
.../pulsar/client/impl/PulsarClientImpl.java | 2 +-
.../pulsar/client/impl/schema/AvroSchema.java | 58 ++++-----
.../impl/schema/SchemaDefinitionBuilderImpl.java | 21 +++-
.../client/impl/schema/SchemaDefinitionImpl.java | 19 ++-
.../client/impl/schema/reader/AvroReader.java | 22 +---
.../client/impl/schema/writer/AvroWriter.java | 10 +-
.../pulsar/client/impl/schema/AvroSchemaTest.java | 38 +++++-
.../client/impl/schema/ProtobufSchemaTest.java | 2 +-
.../pulsar/client/impl/schema/SchemaInfoTest.java | 8 +-
pulsar-discovery-service/pom.xml | 6 -
pulsar-io/hdfs2/pom.xml | 5 -
pulsar-io/hdfs3/pom.xml | 5 -
pulsar-io/mongo/pom.xml | 6 -
pulsar-io/redis/pom.xml | 6 -
pulsar-proxy/pom.xml | 6 -
pulsar-sql/presto-pulsar/pom.xml | 13 ---
tests/integration/pom.xml | 12 ++
...ongoDbContainer.java => RabbitMQContainer.java} | 23 ++--
.../integration/functions/PulsarFunctionsTest.java | 6 +
.../tests/integration/io/RabbitMQSinkTester.java | 109 +++++++++++++++++
.../tests/integration/io/RabbitMQSourceTester.java | 91 +++++++++++++++
.../pulsar/tests/integration/io/SinkTester.java | 3 +-
.../tests/integration/schema/JodaTimeTest.java | 129 +++++++++++++++++++++
.../tests/integration/schema/SchemaTest.java | 10 +-
.../src/test/resources/pulsar-schema.xml | 1 +
48 files changed, 673 insertions(+), 194 deletions(-)
copy
tests/integration/src/test/java/org/apache/pulsar/tests/integration/containers/{DebeziumMongoDbContainer.java
=> RabbitMQContainer.java} (67%)
create mode 100644
tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/RabbitMQSinkTester.java
create mode 100644
tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/RabbitMQSourceTester.java
create mode 100644
tests/integration/src/test/java/org/apache/pulsar/tests/integration/schema/JodaTimeTest.java
