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 873610e [Doc] Use metadata-store and configuration-metadata-store in
initialize-cluster-metadata (#13985)
add 2c428f7 [PIP 79][common,broker,client] Change PartitionedTopicStats
to aggregate by producerName (#12401)
No new revisions were added by this update.
Summary of changes:
conf/broker.conf | 4 +
conf/standalone.conf | 4 +
.../apache/pulsar/broker/ServiceConfiguration.java | 5 +
.../org/apache/pulsar/broker/service/Producer.java | 17 ++-
.../apache/pulsar/broker/service/ServerCnx.java | 12 +-
.../service/nonpersistent/NonPersistentTopic.java | 2 +-
.../broker/service/persistent/PersistentTopic.java | 2 +-
.../apache/pulsar/broker/admin/AdminApi2Test.java | 83 ++++++++++++-
.../pulsar/broker/service/PersistentTopicTest.java | 34 ++---
.../pulsar/client/impl/MessageChunkingTest.java | 2 +-
.../pulsar/client/impl/PulsarTestClient.java | 6 +-
.../common/policies/data/PublisherStats.java | 3 +
.../client/impl/PartitionedProducerImpl.java | 86 ++++++++-----
.../apache/pulsar/client/impl/ProducerImpl.java | 4 +-
.../pulsar/client/impl/PulsarClientImpl.java | 8 +-
.../client/impl/PartitionedProducerImplTest.java | 7 +-
.../data/stats/NonPersistentTopicStatsImpl.java | 71 ++++++++---
.../policies/data/stats/PublisherStatsImpl.java | 3 +
.../common/policies/data/stats/TopicStatsImpl.java | 67 ++++++++--
.../apache/pulsar/common/protocol/Commands.java | 1 +
pulsar-common/src/main/proto/PulsarApi.proto | 1 +
.../policies/data/PartitionedTopicStatsTest.java | 4 +-
.../policies/data/PersistentTopicStatsTest.java | 137 +++++++++++++++++++--
.../common/policies/data/PublisherStatsTest.java | 3 +-
24 files changed, 464 insertions(+), 102 deletions(-)
