You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by gu...@apache.org on 2020/04/06 01:18:09 UTC
[pulsar] branch branch-2.5 updated (ad02244 -> 27b5abe)
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 ad02244 resume servercnx method to public (#6581)
discard 68e5b79 Fixed protobuf-shaded version 2.5.0
discard 58e52e0 Fix NPE while call getLastMessageId. (#6562)
discard e7459b4 Fix: topic with one partition cannot be updated (#6560)
discard bf14a08 Don't increment unacked messages for the consumer with Exclusive/Failover subscription mode. (#6558)
discard b2df780 Disable channel auto read when publish rate or publish buffer exceeded (#6550)
discard b1c9c2f Fix admin getLastMessageId return batchIndex (#6511)
discard 394791d Instead of always using admin access for topic, use read/write/admin access for topic (#6504)
discard 77f2c82 Start namespace service and schema registry service before start broker. (#6499)
discard 1b36a7a [pulsar-client-cpp] Fix Redelivery of Messages on UnackedMessageTracker When Ack Messages . (#6498)
discard 53b4073 [broker] Timeout API calls in BrokerService (#6489)
discard e05b786 [pulsar-client] fix deadlock on send failure (#6488)
discard 4724659 [proxy] Fix proxy routing to functions worker (#6486)
discard 5911b8b Fix memory leak when running topic compaction. (#6485)
discard 1e1dd06 Fix some async method problems at PersistentTopicsBase. (#6483)
discard c4902d6 Avoid calling ConsumerImpl::redeliverMessages() when message list is empty (#6480)
discard b5322bc Fix create partitioned topic with a substring of an existing topic name. (#6478)
discard 89e44ec [pulsar-proxy] fix logging for published messages (#6474)
discard 85257b5 pulsar-proxy: fix correct name for proxy thread executor name (#6460)
discard f94eb89 Improve cpp-client-lib: provide another `libpulsarwithdeps.a` in dep/rpm (#6458)
discard 4becef9 [Broker] Create namespace failed when TLS is enabled in PulsarStandalone (#6457)
discard eb7aa2a Use System.nanoTime() instead of System.currentTimeMillis() (#6454)
discard 56c7079 Fixed the max backoff configuration for lookups (#6444)
discard 0afcf1b fix the bug of authenticationData is't initialized. (#6440)
discard 22fbdc1 [Flink-Connector]Get PulsarClient from cache should always return an open instance (#6436)
discard 6186aef Fix publish buffer limit does not take effect
discard f6fb44d Bump netty version to 4.1.45.Final (#6424)
discard 52d5d7c Update BatchReceivePolicy.java (#6423)
discard 31e3d19 [Java client] MultiTopics discovery is broken due to discovery task scheduled twice instead of pendingBatchRecei… (#6407)
discard 0e9c56a [Issue 3762][Schema] Fix the problem with parsing of an Avro schema related to shading in pulsar-client. (#6406)
discard 379bdec Add verification for SchemaDefinitionBuilderImpl.java (#6405)
discard 3ee06e3 Consumer received duplicated deplayed messages upon restart
discard d36eee2 Fixed enum package not found (#6401)
discard 8cebbbb Close ZK before canceling future with exception (#6228) (#6399)
discard 0cbda7f [Minor] Fix java code errors reported by lgtm. (#6398)
discard 3313e6c Seek to the first one >= timestamp (#6393)
discard eaba596 [Reader] Should set either start message id or start message from roll back duration. (#6392)
discard 8174617 [Issue 6168] Fix Unacked Message Tracker by Using Time Partition on C++ (#6391)
discard 8f1e0d0 fix duplicate key to send propertys (#6390)
discard 59f055b [Pulsar-Client] Stop shade snappy-java in pulsar-client-shaded (#6375)
discard 7fe98b8 [Issue 6355][HELM] autorecovery - could not find or load main class (#6373)
discard e7cf371 Creating a topic does not wait for creating cursor of replicators (#6364)
discard e173f60 [ClientAPI]Fix hasMessageAvailable() (#6362)
discard b4d7dc5 remove future.join() from PulsarSinkEffectivelyOnceProcessor (#6361)
discard 64690bf Independent schema is set for each consumer generated by topic (#6356)
discard 37906e3 Fix broker to specify a list of bookie groups. (#6349)
discard ac59e09 [Java Reader Client] Start reader inside batch result in read first message in batch. (#6345)
discard 08196be Fix java doc for key shared policy. (#6341)
discard e939a51 explicit statement env 'BOOKIE_MEM' and 'BOOKIE_GC' for values-mini.yaml (#6340)
discard e44b822 Avoid get partition metadata while the topic name is a partition name. (#6339)
discard 7112e21 client: make SubscriptionMode a member of ConsumerConfigurationData (#6337)
discard aaf87f6a3 Windows CMake corrections (#6336)
discard eb17206 Upgrade ZooKeeper to 3.5.7 (#6329)
discard c20071b Should flush the last potential duplicated since can't combine potential duplicated messages and non-duplicated messages into a batch. (#6326)
discard b3af045 KeyValue schema support for pulsar sql (#6325)
discard 4ba38bb Fixed casting in ZooKeeperCache.getDataIfPresent() (#6313)
discard ad01245 Enable get precise backlog and backlog without delayed messages. (#6310)
discard bf0f4a7 Remove problematic semicolon from conf (#6303)
discard d3063da [Issue 4070][pulsar-client-cpp] Fix for possible deadlock when closing Pulsar client (#6277)
discard d25cb39 Fix bug that tenants whose allowed clusters include global cannot be created/updated (#6275)
discard 8f56884 [C++] Fixed handling of canceled timer events on NegativeAcksTracker (#6272)
discard ef40db5 [C++] Fixed memory corruption on ExecutorService destructor (#6270)
new 274b67e Make tests more stable by using JSONAssert equals (#6247)
new fafb6fa [C++] Fixed memory corruption on ExecutorService destructor (#6270)
new 55b1254 [C++] Fixed handling of canceled timer events on NegativeAcksTracker (#6272)
new 59965cb Fix bug that tenants whose allowed clusters include global cannot be created/updated (#6275)
new 03f6286 [Issue 4070][pulsar-client-cpp] Fix for possible deadlock when closing Pulsar client (#6277)
new a93efc6 Remove problematic semicolon from conf (#6303)
new 3329f42 Enable get precise backlog and backlog without delayed messages. (#6310)
new a344229 Fixed casting in ZooKeeperCache.getDataIfPresent() (#6313)
new afe1aa3 KeyValue schema support for pulsar sql (#6325)
new 3790518 Should flush the last potential duplicated since can't combine potential duplicated messages and non-duplicated messages into a batch. (#6326)
new 3868669 Upgrade ZooKeeper to 3.5.7 (#6329)
new dffe575 Windows CMake corrections (#6336)
new 55dd789 client: make SubscriptionMode a member of ConsumerConfigurationData (#6337)
new 0abaaee Avoid get partition metadata while the topic name is a partition name. (#6339)
new a67adb4 explicit statement env 'BOOKIE_MEM' and 'BOOKIE_GC' for values-mini.yaml (#6340)
new e939f55 Fix java doc for key shared policy. (#6341)
new 0002a25 [Java Reader Client] Start reader inside batch result in read first message in batch. (#6345)
new 6af87b6 Fix broker to specify a list of bookie groups. (#6349)
new 7ff6b8b Independent schema is set for each consumer generated by topic (#6356)
new 12a5dd5 remove future.join() from PulsarSinkEffectivelyOnceProcessor (#6361)
new 37da6ce [ClientAPI]Fix hasMessageAvailable() (#6362)
new 4cee828 Creating a topic does not wait for creating cursor of replicators (#6364)
new 151b762 [Issue 6355][HELM] autorecovery - could not find or load main class (#6373)
new d2a20dd [Pulsar-Client] Stop shade snappy-java in pulsar-client-shaded (#6375)
new ccc8e69 fix duplicate key to send propertys (#6390)
new 8fe10ba [Issue 6168] Fix Unacked Message Tracker by Using Time Partition on C++ (#6391)
new 3ba9728 [Reader] Should set either start message id or start message from roll back duration. (#6392)
new 9bce472 Seek to the first one >= timestamp (#6393)
new 1061ac8 [Minor] Fix java code errors reported by lgtm. (#6398)
new 211d7f0 Close ZK before canceling future with exception (#6228) (#6399)
new 81c3244 Fixed enum package not found (#6401)
new 5db1329 Consumer received duplicated deplayed messages upon restart
new 4ca6ab1 Add verification for SchemaDefinitionBuilderImpl.java (#6405)
new 3c9a442 [Issue 3762][Schema] Fix the problem with parsing of an Avro schema related to shading in pulsar-client. (#6406)
new a57861f [Java client] MultiTopics discovery is broken due to discovery task scheduled twice instead of pendingBatchRecei… (#6407)
new ecbe886 Update BatchReceivePolicy.java (#6423)
new 45f1272 Bump netty version to 4.1.45.Final (#6424)
new 9834056 Fix publish buffer limit does not take effect
new ae741cf [Flink-Connector]Get PulsarClient from cache should always return an open instance (#6436)
new c412275 fix the bug of authenticationData is't initialized. (#6440)
new eb3a481 Fixed the max backoff configuration for lookups (#6444)
new 49de49f Use System.nanoTime() instead of System.currentTimeMillis() (#6454)
new 546e1fe [Broker] Create namespace failed when TLS is enabled in PulsarStandalone (#6457)
new 5138b4a Improve cpp-client-lib: provide another `libpulsarwithdeps.a` in dep/rpm (#6458)
new 3683f30 pulsar-proxy: fix correct name for proxy thread executor name (#6460)
new 98a57df [pulsar-proxy] fix logging for published messages (#6474)
new 1c19557 Fix create partitioned topic with a substring of an existing topic name. (#6478)
new 7c76082 Avoid calling ConsumerImpl::redeliverMessages() when message list is empty (#6480)
new c23ab86 Fix some async method problems at PersistentTopicsBase. (#6483)
new d618dcb Fix memory leak when running topic compaction. (#6485)
new fb32d85 [proxy] Fix proxy routing to functions worker (#6486)
new 79b8259 [pulsar-client] fix deadlock on send failure (#6488)
new 10e3499 [broker] Timeout API calls in BrokerService (#6489)
new 5076755 [pulsar-client-cpp] Fix Redelivery of Messages on UnackedMessageTracker When Ack Messages . (#6498)
new c0c5880 Start namespace service and schema registry service before start broker. (#6499)
new c735e13 Instead of always using admin access for topic, use read/write/admin access for topic (#6504)
new 921e5f8 Fix admin getLastMessageId return batchIndex (#6511)
new e310de3 [Maven Cleanup] Remove managed-ledger and zk-utils test-jar dependencies when possible (#6513)
new 166498b Disable channel auto read when publish rate or publish buffer exceeded (#6550)
new a458fce Don't increment unacked messages for the consumer with Exclusive/Failover subscription mode. (#6558)
new b66f11c Fix: topic with one partition cannot be updated (#6560)
new 4cdd4de Fix NPE while call getLastMessageId. (#6562)
new e82ef7a resume servercnx method to public (#6581)
new 0a8243e Support BouncyCastle FIPS provider (#6588)
new 0d16f77 Fixed avro schema decode error in functions (#6662)
new 40e9c5e Improve Key_Shared subscription message dispatching performance. (#6647)
new 27b5abe Move 2.6.0-SNAPSHOT to 2.5.0
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 (ad02244)
\
N -- N -- N refs/heads/branch-2.5 (27b5abe)
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 67 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-unit-broker.yml | 145 +++++++++++++++++++++
.../bc-shaded}/pom.xml | 48 ++++---
.../LICENSE.txt => bouncy-castle/bc/LICENSE | 17 +--
{pulsar-io/kafka => bouncy-castle/bc}/pom.xml | 31 ++---
.../apache/pulsar/bcloader/BouncyCastleLoader.java | 34 +++--
.../resources/META-INF/services/bouncy-castle.yaml | 7 +-
.../bcfips-include-test}/pom.xml | 49 ++++---
.../pulsar/client}/TlsProducerConsumerBase.java | 9 +-
.../pulsar/client}/TlsProducerConsumerTest.java | 7 +-
.../resources/authentication/tls/broker-cert.pem | 0
.../resources/authentication/tls/broker-key.pem | 0
.../test/resources/authentication/tls/cacert.pem | 0
.../resources/authentication/tls/client-cert.pem | 0
.../resources/authentication/tls/client-key.pem | 0
.../bcfips-nar-test}/pom.xml | 73 +++++------
.../pulsar/client}/TlsProducerConsumerBase.java | 27 +++-
.../pulsar/client}/TlsProducerConsumerTest.java | 7 +-
.../resources/authentication/tls/broker-cert.pem | 0
.../resources/authentication/tls/broker-key.pem | 0
.../test/resources/authentication/tls/cacert.pem | 0
.../resources/authentication/tls/client-cert.pem | 0
.../resources/authentication/tls/client-key.pem | 0
.../LICENSE.txt => bouncy-castle/bcfips/LICENSE | 16 +--
{pulsar-io/kafka => bouncy-castle/bcfips}/pom.xml | 31 ++---
.../pulsar/bcloader/BouncyCastleFipsLoader.java | 34 +++--
.../resources/META-INF/services/bouncy-castle.yaml | 7 +-
{pulsar-client-1x-base => bouncy-castle}/pom.xml | 20 ++-
distribution/server/pom.xml | 5 +
distribution/server/src/assemble/LICENSE.bin.txt | 6 -
managed-ledger/pom.xml | 7 +
.../mledger/impl/ManagedLedgerBkTest.java | 2 -
.../bookkeeper/mledger/impl/ManagedLedgerTest.java | 1 -
pom.xml | 20 ++-
pulsar-broker-auth-athenz/pom.xml | 5 +-
pulsar-broker-auth-sasl/pom.xml | 13 +-
pulsar-broker-common/pom.xml | 6 -
pulsar-broker-shaded/pom.xml | 2 +
pulsar-broker/pom.xml | 16 ++-
...ashRangeAutoSplitStickyKeyConsumerSelector.java | 14 ++
...ashRangeExclusiveStickyKeyConsumerSelector.java | 22 ++++
.../apache/pulsar/broker/service/ServerCnx.java | 4 +-
.../broker/service/StickyKeyConsumerSelector.java | 9 ++
...istentStickyKeyDispatcherMultipleConsumers.java | 4 +-
...istentStickyKeyDispatcherMultipleConsumers.java | 4 +-
.../pulsar/broker/service/BatchMessageTest.java | 26 ++--
.../client/api/SimpleProducerConsumerTest.java | 12 +-
.../pulsar-client-2x-shaded/pom.xml | 2 +-
pulsar-client-admin-shaded/pom.xml | 2 +
pulsar-client-all/pom.xml | 9 ++
pulsar-client-api/pom.xml | 7 +
.../apache/pulsar/client/api/ConsumerBuilder.java | 11 ++
.../apache/pulsar/client/api/MessageCrypto.java | 81 ++++++++++++
.../pulsar-client-kafka-tests/pom.xml | 6 +-
.../pulsar-client-kafka-tests_0_8/pom.xml | 5 +-
.../pulsar-client-kafka-tests_0_9/pom.xml | 5 +-
.../pulsar-client-kafka_0_8/pom.xml | 6 +-
.../pom.xml | 25 ++--
.../pulsar/client/impl/crypto/MessageCryptoBc.java | 49 +++----
pulsar-client-shaded/pom.xml | 14 +-
pulsar-client-tools-test/pom.xml | 5 +-
pulsar-client/pom.xml | 27 +++-
.../pulsar/client/impl/ConsumerBuilderImpl.java | 7 +
.../apache/pulsar/client/impl/ConsumerImpl.java | 22 +++-
.../apache/pulsar/client/impl/ProducerImpl.java | 35 +++--
.../pulsar/client/impl/auth/AuthenticationTls.java | 10 +-
.../impl/conf/ConsumerConfigurationData.java | 4 +
.../impl/conf/ProducerConfigurationData.java | 4 +
.../pulsar/client/impl/schema/AvroSchema.java | 27 ++--
.../client/impl/schema/reader/AvroReader.java | 33 ++++-
.../pulsar/client/impl/schema/AvroSchemaTest.java | 14 +-
pulsar-common/pom.xml | 5 -
.../{naming/Constants.java => util/BCLoader.java} | 13 +-
.../apache/pulsar/common/util/BcNarDefinition.java | 13 +-
.../pulsar/common/util/SearchBcNarUtils.java | 116 +++++++++++++++++
.../apache/pulsar/common/util/SecurityUtility.java | 72 +++++++++-
pulsar-discovery-service/pom.xml | 26 ++--
.../functions/instance/JavaInstanceRunnable.java | 4 +-
.../pulsar/functions/source/PulsarSource.java | 3 +-
...ngFunction.java => AvroSchemaTestFunction.java} | 20 ++-
.../api/examples/WindowDurationFunction.java | 1 +
.../api/examples/pojo/AvroTestObject.java | 12 +-
pulsar-functions/worker/pom.xml | 15 +++
pulsar-io/debezium/core/pom.xml | 13 +-
pulsar-io/kafka-connect-adaptor/pom.xml | 13 +-
pulsar-proxy/pom.xml | 5 +-
.../pulsar/proxy/server/ProxyServiceStarter.java | 2 -
pulsar-sql/presto-distribution/LICENSE | 9 +-
pulsar-testclient/pom.xml | 37 ++++--
pulsar-zookeeper-utils/pom.xml | 24 +---
.../pulsar/zookeeper/ZookeeperServerTest.java | 1 -
site2/docs/security-bouncy-castle.md | 121 +++++++++++++++++
site2/docs/security-tls-authentication.md | 2 +
site2/docs/security-tls-transport.md | 2 +
site2/website/sidebars.json | 3 +-
{pulsar-client-auth-athenz => testmocks}/pom.xml | 31 +++--
.../bookkeeper/client/BookKeeperTestClient.java | 0
.../bookkeeper/client/PulsarMockBookKeeper.java | 2 -
.../bookkeeper/client/PulsarMockLedgerHandle.java | 3 +-
.../bookkeeper/client/PulsarMockReadHandle.java | 0
.../java/org/apache/zookeeper/MockZooKeeper.java | 0
.../latest-version-image/conf/bookie.conf | 2 +-
.../integration/functions/PulsarFunctionsTest.java | 131 ++++++++++++++++++-
tests/pulsar-storm-test/pom.xml | 3 +-
tiered-storage/file-system/pom.xml | 5 +-
tiered-storage/jcloud/pom.xml | 3 +-
105 files changed, 1362 insertions(+), 500 deletions(-)
create mode 100644 .github/workflows/ci-unit-broker.yml
copy {protobuf-shaded => bouncy-castle/bc-shaded}/pom.xml (57%)
copy pulsar-client-cpp/pkg/licenses/LICENSE.txt => bouncy-castle/bc/LICENSE (96%)
copy {pulsar-io/kafka => bouncy-castle/bc}/pom.xml (72%)
copy pulsar-functions/java-examples/src/main/java/org/apache/pulsar/functions/api/examples/ContextWindowFunction.java => bouncy-castle/bc/src/main/java/org/apache/pulsar/bcloader/BouncyCastleLoader.java (55%)
copy dashboard/django/collector.sh => bouncy-castle/bc/src/main/resources/META-INF/services/bouncy-castle.yaml (86%)
mode change 100755 => 100644
copy {pulsar-client-tools-test => bouncy-castle/bcfips-include-test}/pom.xml (67%)
copy {pulsar-broker/src/test/java/org/apache/pulsar/client/api => bouncy-castle/bcfips-include-test/src/test/java/org/apache/pulsar/client}/TlsProducerConsumerBase.java (96%)
copy {pulsar-broker/src/test/java/org/apache/pulsar/client/api => bouncy-castle/bcfips-include-test/src/test/java/org/apache/pulsar/client}/TlsProducerConsumerTest.java (95%)
copy {pulsar-broker => bouncy-castle/bcfips-include-test}/src/test/resources/authentication/tls/broker-cert.pem (100%)
copy {pulsar-broker => bouncy-castle/bcfips-include-test}/src/test/resources/authentication/tls/broker-key.pem (100%)
copy {pulsar-proxy => bouncy-castle/bcfips-include-test}/src/test/resources/authentication/tls/cacert.pem (100%)
copy {pulsar-proxy => bouncy-castle/bcfips-include-test}/src/test/resources/authentication/tls/client-cert.pem (100%)
copy {pulsar-proxy => bouncy-castle/bcfips-include-test}/src/test/resources/authentication/tls/client-key.pem (100%)
copy {pulsar-client-tools => bouncy-castle/bcfips-nar-test}/pom.xml (60%)
copy {pulsar-broker/src/test/java/org/apache/pulsar/client/api => bouncy-castle/bcfips-nar-test/src/test/java/org/apache/pulsar/client}/TlsProducerConsumerBase.java (85%)
copy {pulsar-broker/src/test/java/org/apache/pulsar/client/api => bouncy-castle/bcfips-nar-test/src/test/java/org/apache/pulsar/client}/TlsProducerConsumerTest.java (95%)
copy {pulsar-broker => bouncy-castle/bcfips-nar-test}/src/test/resources/authentication/tls/broker-cert.pem (100%)
copy {pulsar-broker => bouncy-castle/bcfips-nar-test}/src/test/resources/authentication/tls/broker-key.pem (100%)
copy {pulsar-proxy => bouncy-castle/bcfips-nar-test}/src/test/resources/authentication/tls/cacert.pem (100%)
copy {pulsar-proxy => bouncy-castle/bcfips-nar-test}/src/test/resources/authentication/tls/client-cert.pem (100%)
copy {pulsar-proxy => bouncy-castle/bcfips-nar-test}/src/test/resources/authentication/tls/client-key.pem (100%)
copy pulsar-client-cpp/pkg/licenses/LICENSE.txt => bouncy-castle/bcfips/LICENSE (96%)
copy {pulsar-io/kafka => bouncy-castle/bcfips}/pom.xml (72%)
copy pulsar-functions/java-examples/src/main/java/org/apache/pulsar/functions/api/examples/ContextWindowFunction.java => bouncy-castle/bcfips/src/main/java/org/apache/pulsar/bcloader/BouncyCastleFipsLoader.java (53%)
copy dashboard/django/collector.sh => bouncy-castle/bcfips/src/main/resources/META-INF/services/bouncy-castle.yaml (84%)
mode change 100755 => 100644
copy {pulsar-client-1x-base => bouncy-castle}/pom.xml (71%)
create mode 100644 pulsar-client-api/src/main/java/org/apache/pulsar/client/api/MessageCrypto.java
copy {pulsar-client-1x-base/pulsar-client-1x => pulsar-client-messagecrypto-bc}/pom.xml (75%)
rename pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessageCrypto.java => pulsar-client-messagecrypto-bc/src/main/java/org/apache/pulsar/client/impl/crypto/MessageCryptoBc.java (94%)
copy pulsar-common/src/main/java/org/apache/pulsar/common/{naming/Constants.java => util/BCLoader.java} (81%)
copy managed-ledger/src/main/java/org/apache/bookkeeper/mledger/offload/OffloaderDefinition.java => pulsar-common/src/main/java/org/apache/pulsar/common/util/BcNarDefinition.java (77%)
create mode 100644 pulsar-common/src/main/java/org/apache/pulsar/common/util/SearchBcNarUtils.java
copy pulsar-functions/java-examples/src/main/java/org/apache/pulsar/functions/api/examples/{ConsistentlyFailingFunction.java => AvroSchemaTestFunction.java} (68%)
copy pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/ExceptionInformation.java => pulsar-functions/java-examples/src/main/java/org/apache/pulsar/functions/api/examples/pojo/AvroTestObject.java (84%)
create mode 100644 site2/docs/security-bouncy-castle.md
copy {pulsar-client-auth-athenz => testmocks}/pom.xml (69%)
rename {managed-ledger/src/test => testmocks/src/main}/java/org/apache/bookkeeper/client/BookKeeperTestClient.java (100%)
rename {managed-ledger/src/test => testmocks/src/main}/java/org/apache/bookkeeper/client/PulsarMockBookKeeper.java (99%)
rename {managed-ledger/src/test => testmocks/src/main}/java/org/apache/bookkeeper/client/PulsarMockLedgerHandle.java (99%)
rename {managed-ledger/src/test => testmocks/src/main}/java/org/apache/bookkeeper/client/PulsarMockReadHandle.java (100%)
rename {managed-ledger/src/test => testmocks/src/main}/java/org/apache/zookeeper/MockZooKeeper.java (100%)