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