[pulsar] branch master updated (8d3c0df -> 12ef7c9)
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 8d3c0df Fix gc log variable judge in jdk8 (#8579)
add 12ef7c9 Support partitioned topics in the Reader (#7518)
No new revisions were added by this update.
Summary of changes:
.../broker/service/SubscriptionSeekTest.java | 3 +-
.../apache/pulsar/client/api/TopicReaderTest.java | 507 -
...{ReaderTest.java => MultiTopicsReaderTest.java} | 271 ++-
.../apache/pulsar/client/impl/ConsumerImpl.java| 22 +-
.../apache/pulsar/client/impl/MessageIdImpl.java | 13 +
.../client/impl/MultiTopicsConsumerImpl.java | 100 +++-
...{ReaderImpl.java => MultiTopicsReaderImpl.java} | 136 +++---
.../pulsar/client/impl/PulsarClientImpl.java | 19 +-
8 files changed, 836 insertions(+), 235 deletions(-)
copy
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/{ReaderTest.java =>
MultiTopicsReaderTest.java} (74%)
copy
pulsar-client/src/main/java/org/apache/pulsar/client/impl/{ReaderImpl.java =>
MultiTopicsReaderImpl.java} (60%)
[pulsar] branch master updated (8d3c0df -> 12ef7c9)
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 8d3c0df Fix gc log variable judge in jdk8 (#8579)
add 12ef7c9 Support partitioned topics in the Reader (#7518)
No new revisions were added by this update.
Summary of changes:
.../broker/service/SubscriptionSeekTest.java | 3 +-
.../apache/pulsar/client/api/TopicReaderTest.java | 507 -
...{ReaderTest.java => MultiTopicsReaderTest.java} | 271 ++-
.../apache/pulsar/client/impl/ConsumerImpl.java| 22 +-
.../apache/pulsar/client/impl/MessageIdImpl.java | 13 +
.../client/impl/MultiTopicsConsumerImpl.java | 100 +++-
...{ReaderImpl.java => MultiTopicsReaderImpl.java} | 136 +++---
.../pulsar/client/impl/PulsarClientImpl.java | 19 +-
8 files changed, 836 insertions(+), 235 deletions(-)
copy
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/{ReaderTest.java =>
MultiTopicsReaderTest.java} (74%)
copy
pulsar-client/src/main/java/org/apache/pulsar/client/impl/{ReaderImpl.java =>
MultiTopicsReaderImpl.java} (60%)
[pulsar] branch master updated (8d3c0df -> 12ef7c9)
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 8d3c0df Fix gc log variable judge in jdk8 (#8579)
add 12ef7c9 Support partitioned topics in the Reader (#7518)
No new revisions were added by this update.
Summary of changes:
.../broker/service/SubscriptionSeekTest.java | 3 +-
.../apache/pulsar/client/api/TopicReaderTest.java | 507 -
...{ReaderTest.java => MultiTopicsReaderTest.java} | 271 ++-
.../apache/pulsar/client/impl/ConsumerImpl.java| 22 +-
.../apache/pulsar/client/impl/MessageIdImpl.java | 13 +
.../client/impl/MultiTopicsConsumerImpl.java | 100 +++-
...{ReaderImpl.java => MultiTopicsReaderImpl.java} | 136 +++---
.../pulsar/client/impl/PulsarClientImpl.java | 19 +-
8 files changed, 836 insertions(+), 235 deletions(-)
copy
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/{ReaderTest.java =>
MultiTopicsReaderTest.java} (74%)
copy
pulsar-client/src/main/java/org/apache/pulsar/client/impl/{ReaderImpl.java =>
MultiTopicsReaderImpl.java} (60%)
