You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by zh...@apache.org on 2020/12/12 05:16:08 UTC
[pulsar] branch master updated (b63e288 -> 6275297)
This is an automated email from the ASF dual-hosted git repository.
zhaijia pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from b63e288 Support configure max subscriptions per topic on the namespace level policy (#8924)
add 6275297 [PIP 70][Issue 8617] Introduce lightweight broker entry metadata (#8618)
No new revisions were added by this update.
Summary of changes:
.../bookkeeper/mledger/ManagedLedgerConfig.java | 1 +
.../apache/bookkeeper/mledger/impl/OpAddEntry.java | 7 +-
.../apache/pulsar/broker/ServiceConfiguration.java | 6 +
.../pulsar/broker/service/BrokerService.java | 17 +
.../broker/service/BrokerServiceException.java | 6 +
.../broker/service/PulsarCommandSenderImpl.java | 2 +
.../apache/pulsar/broker/service/ServerCnx.java | 5 +
.../nonpersistent/NonPersistentReplicator.java | 2 +-
.../persistent/PersistentMessageExpiryMonitor.java | 4 +-
.../persistent/PersistentMessageFinder.java | 6 +-
.../service/persistent/PersistentReplicator.java | 2 +-
.../broker/service/persistent/PersistentTopic.java | 34 +-
.../service/PersistentMessageFinderTest.java | 126 +++++++
.../org/apache/pulsar/client/impl/MessageImpl.java | 73 +++-
.../apache/pulsar/common/api/proto/PulsarApi.java | 380 +++++++++++++++++++++
.../AppendBrokerTimestampMetadataInterceptor.java | 15 +-
...on.java => BrokerEntryMetadataInterceptor.java} | 17 +-
.../common/intercept/BrokerEntryMetadataUtils.java | 58 ++++
.../apache/pulsar/common/protocol/Commands.java | 79 +++++
pulsar-common/src/main/proto/PulsarApi.proto | 7 +
.../pulsar/common/protocol/CommandUtilsTests.java | 104 ++++++
.../pulsar/sql/presto/PulsarSplitManager.java | 9 +-
tests/{bc_2_0_1 => bc_2_6_0}/pom.xml | 25 +-
.../pulsar/tests/integration/PulsarContainer.java | 0
.../apache/pulsar/tests/integration/SmokeTest.java | 0
.../src/test/resources/backwards-client.xml} | 0
tests/pom.xml | 1 +
27 files changed, 938 insertions(+), 48 deletions(-)
copy pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/exceptions/UnsupportedTxnActionException.java => pulsar-common/src/main/java/org/apache/pulsar/common/intercept/AppendBrokerTimestampMetadataInterceptor.java (63%)
copy pulsar-common/src/main/java/org/apache/pulsar/common/intercept/{InterceptException.java => BrokerEntryMetadataInterceptor.java} (70%)
create mode 100644 pulsar-common/src/main/java/org/apache/pulsar/common/intercept/BrokerEntryMetadataUtils.java
copy tests/{bc_2_0_1 => bc_2_6_0}/pom.xml (87%)
copy tests/{bc_2_0_1 => bc_2_6_0}/src/test/java/org/apache/pulsar/tests/integration/PulsarContainer.java (100%)
copy tests/{bc_2_0_1 => bc_2_6_0}/src/test/java/org/apache/pulsar/tests/integration/SmokeTest.java (100%)
copy tests/{bc_2_0_1/src/test/resources/pulsar.xml => bc_2_6_0/src/test/resources/backwards-client.xml} (100%)