You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@pulsar.apache.org by pe...@apache.org on 2020/05/29 09:35:49 UTC

[pulsar] branch master updated (8b7b60e -> 4883e1b)

This is an automated email from the ASF dual-hosted git repository.

penghui pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.


    from 8b7b60e  Allow managed cursor to specify max read batch in bytes (#7060)
     add 4883e1b  fix consumer fetch message number maps to read entry number bug and expose avgMessagesPerEntry metric (#6719)

No new revisions were added by this update.

Summary of changes:
 conf/broker.conf                                   |  3 +++
 conf/standalone.conf                               |  3 +++
 .../apache/pulsar/broker/ServiceConfiguration.java |  7 +++++
 .../AbstractDispatcherMultipleConsumers.java       | 18 +++++++++++++
 .../org/apache/pulsar/broker/service/Consumer.java | 30 ++++++++++++++++++++++
 .../apache/pulsar/broker/service/ServerCnx.java    |  6 +++++
 .../pulsar/broker/service/StreamingStats.java      |  1 +
 .../PersistentDispatcherMultipleConsumers.java     |  7 +++++
 .../PersistentDispatcherSingleActiveConsumer.java  |  5 ++++
 .../broker/auth/MockedPulsarServiceBaseTest.java   | 29 +++++++++++++++++++++
 .../api/ConsumerPreciseDispatcherFlowControl.java  | 19 +++++++-------
 .../client/api/SimpleProducerConsumerTest.java     |  1 -
 .../pulsar/common/policies/data/ConsumerStats.java |  3 +++
 13 files changed, 121 insertions(+), 11 deletions(-)
 copy pulsar-client-api/src/main/java/org/apache/pulsar/client/api/TopicMetadata.java => pulsar-broker/src/test/java/org/apache/pulsar/client/api/ConsumerPreciseDispatcherFlowControl.java (74%)