This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a change to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from ccb9ba22b14 [fix][io] Fix Kinesis checkpoint mechanism to prevent data
duplication (#24534)
new f1974aa6af5 [fix][ml] Fix asyncReadEntries might never complete if
empty entries are read from BK (#24515)
new b648f514816 [fix][client] Fix ClientCnx handleSendError NPE (#24517)
new e9c1ad04e0e [fix][ws] Fix WebSocket authorization issue due to
originalPrincipal must be provided (#24533)
new 455a0529eab [fix][broker]Fix thread safety issues in
BucketDelayedDeliveryTracker with StampedLock optimistic reads (#24542)
new faa4c75b461 [improve][client] Add `startTimestamp` and `endTimestamp`
for consuming message in client cli (#24521)
new 6a0ff5393f9 [fix][client] Close orphan producer or consumer when the
creation is interrupted (#24539)
new 941cda99203 [fix][misc] Fix topics pattern consumer backwards
compatibility (#24537)
new 0a21e64e6b2 [fix][broker] Fix matching of topicsPattern for topic
names which contain non-ascii characters (#24543)
The 8 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
conf/broker.conf | 10 +
conf/standalone.conf | 10 +
.../mledger/impl/ManagedLedgerFactoryImpl.java | 31 +-
.../bookkeeper/mledger/impl/ManagedLedgerImpl.java | 5 +-
.../bookkeeper/mledger/impl/OpReadEntry.java | 104 +++--
.../mledger/impl/cache/RangeEntryCacheImpl.java | 5 +-
.../bookkeeper/mledger/impl/ManagedCursorTest.java | 38 ++
.../bookkeeper/test/MockedBookKeeperTestCase.java | 22 +-
...ucketDelayedDeliveryTrackerSimpleBenchmark.java | 408 +++++++++++++++++++
.../pulsar/broker/delayed/bucket/package-info.java | 13 +-
.../apache/pulsar/broker/ServiceConfiguration.java | 15 +
.../AuthenticationDataSubscription.java | 22 +-
.../broker/authorization/AuthorizationService.java | 29 +-
.../pulsar/broker/resources/TopicResources.java | 2 +-
.../broker/resources/TopicResourcesTest.java | 9 +
.../broker/admin/impl/PersistentTopicsBase.java | 2 +-
.../bucket/BucketDelayedDeliveryTracker.java | 96 +++--
.../pulsar/broker/lookup/TopicLookupBase.java | 31 +-
.../apache/pulsar/broker/service/ServerCnx.java | 48 +--
.../pulsar/broker/service/TopicListService.java | 39 +-
.../pulsar/broker/web/PulsarWebResource.java | 4 +-
...cketDelayedDeliveryTrackerThreadSafetyTest.java | 433 +++++++++++++++++++++
.../pulsar/broker/service/ServerCnxTest.java | 26 +-
.../broker/service/TopicListServiceTest.java | 16 +-
.../broker/service/TopicListWatcherTest.java | 7 +-
.../pulsar/client/impl/ClientInterruptTest.java | 188 +++++++++
.../pulsar/client/impl/ConsumerCloseTest.java | 47 ---
.../impl/PatternTopicsConsumerImplAuthTest.java | 2 +-
.../client/impl/PatternTopicsConsumerImplTest.java | 28 +-
.../common/naming/ServiceConfigurationTest.java | 19 +
.../proxy/WebSocketProxyAuthIntegrationTest.java | 425 ++++++++++++++++++++
.../org/apache/pulsar/client/cli/CmdConsume.java | 25 +-
.../pulsar/client/impl/ClientBuilderImpl.java | 5 +
.../org/apache/pulsar/client/impl/ClientCnx.java | 19 +-
.../pulsar/client/impl/ConsumerBuilderImpl.java | 26 +-
.../impl/PatternMultiTopicsConsumerImpl.java | 23 +-
.../pulsar/client/impl/ProducerBuilderImpl.java | 2 +-
.../pulsar/client/impl/PulsarClientImpl.java | 5 +-
.../pulsar/client/impl/ReaderBuilderImpl.java | 2 +-
.../pulsar/client/impl/TopicListWatcher.java | 10 +-
.../client/impl/conf/ClientConfigurationData.java | 6 +
.../impl/PatternMultiTopicsConsumerImplTest.java | 9 +-
.../pulsar/client/impl/TopicListWatcherTest.java | 7 +-
.../pulsar/common/lookup/GetTopicsResult.java | 4 +-
.../org/apache/pulsar/common/naming/Constants.java | 2 +
.../pulsar/common/topics/JDKTopicsPattern.java | 36 +-
...ackage-info.java => MatchAllTopicsPattern.java} | 19 +
.../pulsar/common/topics/RE2JTopicsPattern.java | 25 +-
.../org/apache/pulsar/common/topics/TopicList.java | 24 +-
.../apache/pulsar/common/topics/TopicsPattern.java | 84 ++++
.../pulsar/common/topics/TopicsPatternFactory.java | 103 +++++
.../org/apache/pulsar/common/util/FutureUtil.java | 29 ++
.../apache/pulsar/common/topics/TopicListTest.java | 9 +-
.../common/topics/TopicsPatternFactoryTest.java | 136 +++++++
.../pulsar/common/topics/TopicsPatternTest.java | 74 ++++
.../apache/pulsar/websocket/WebSocketService.java | 5 +
56 files changed, 2459 insertions(+), 364 deletions(-)
create mode 100644
microbench/src/main/java/org/apache/pulsar/broker/delayed/bucket/BucketDelayedDeliveryTrackerSimpleBenchmark.java
copy pulsar-common/src/main/java/org/apache/pulsar/common/tls/DomainType.java
=>
microbench/src/main/java/org/apache/pulsar/broker/delayed/bucket/package-info.java
(70%)
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/delayed/bucket/BucketDelayedDeliveryTrackerThreadSafetyTest.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/ClientInterruptTest.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/websocket/proxy/WebSocketProxyAuthIntegrationTest.java
copy
pulsar-broker/src/test/java/org/apache/pulsar/broker/testcontext/NonClosableMockBookKeeper.java
=>
pulsar-common/src/main/java/org/apache/pulsar/common/topics/JDKTopicsPattern.java
(55%)
copy
pulsar-common/src/main/java/org/apache/pulsar/common/topics/{package-info.java
=> MatchAllTopicsPattern.java} (62%)
copy
pulsar-client/src/main/java/org/apache/pulsar/client/impl/JavaStringHash.java
=>
pulsar-common/src/main/java/org/apache/pulsar/common/topics/RE2JTopicsPattern.java
(60%)
create mode 100644
pulsar-common/src/main/java/org/apache/pulsar/common/topics/TopicsPattern.java
create mode 100644
pulsar-common/src/main/java/org/apache/pulsar/common/topics/TopicsPatternFactory.java
create mode 100644
pulsar-common/src/test/java/org/apache/pulsar/common/topics/TopicsPatternFactoryTest.java
create mode 100644
pulsar-common/src/test/java/org/apache/pulsar/common/topics/TopicsPatternTest.java
