This is an automated email from the ASF dual-hosted git repository.
rgao pushed a change to branch branch-2.9
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 7792fac [pulsar-io] pass client builder if no service url provided to
debezium connector (#12145) (#14041)
new 1e17289 [security] Upgrade Postgre driver to 42.2.25 to get rid of
CVE-2022-21724 (#14119)
new b70f6cd [Transaction] Optimize
testEndTBRecoveringWhenManagerLedgerDisReadable (#14303)
new 8279db9 Fix the wrong parameter in the log. (#14309)
new c16083e [Broker] Change broker producer fence log level (#14196)
new 0e438a9 [Flaky-Test]
BacklogQuotaManagerTest#testProducerExceptionAndThenUnblockSizeQuota (#14213)
new d6867b4 [Websocket] Fix ``ClassCastException`` when user create
``MultiTopicReader``. (#14316)
new 44408bf Fix adding message to list potential issue (#14377)
new e583b05 [Broker] waitingCursors potential heap memory leak (#13939)
new 718a95b Fix send to deadLetterTopic not working when reach
maxRedeliverCount (#14317)
new 3101b66 [C++] Fix GCC compilation failure caused by warning macro
(#14402)
new 982a11f [Transaction] delete changeMaxReadPositionAndAddAbortTimes
when checkIfNoSnapshot (#14276)
new 45c74fb [Transaction] Adopt single thread pool in TC (#14238)
new 6094879 Fix ConsumerBuilderImpl#subscribeAsync blocks calling thread.
(#14433)
new 86fa496 [Pulsar SQL] Fix PulsarRecordCursor deserialize issue.
(#14379)
new a5a9991 [Transaction] Adopt Single_thread to handle TcClient
connecting (#13969)
new 3089aa4 [Transaction] Fix end transaction at state of timeout (#14370)
new 2bc8f48 Fix can't read the latest message of the compacted topic
(#14449)
new 4e79741 Validate rack name (#14336)
new 56f1660 [pulsar-broker] Fix avg-messagePerEntry metrics for consumer
(#14330)
new 5047498 fix npe in ManagedLedgerImpl (#14481)
new d87a230 [Broker] Fix ``Future.join()`` causing deadlock. (#14469)
The 21 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:
.../apache/bookkeeper/mledger/ManagedCursor.java | 6 +-
.../apache/bookkeeper/mledger/ManagedLedger.java | 7 +
.../bookkeeper/mledger/impl/ManagedCursorImpl.java | 11 +-
.../bookkeeper/mledger/impl/ManagedLedgerImpl.java | 8 +-
.../mledger/impl/ManagedCursorContainerTest.java | 3 +-
.../bookkeeper/mledger/impl/ManagedCursorTest.java | 6 +-
.../mledger/impl/NonDurableCursorTest.java | 2 +-
pom.xml | 3 +-
.../org/apache/pulsar/broker/PulsarService.java | 5 +
.../broker/TransactionMetadataStoreService.java | 152 +++++-----
.../org/apache/pulsar/broker/admin/v2/Bookies.java | 16 +
.../org/apache/pulsar/broker/service/Consumer.java | 2 +-
.../apache/pulsar/broker/service/ServerCnx.java | 11 +-
.../SystemTopicBasedTopicPoliciesService.java | 2 +-
.../service/persistent/PersistentSubscription.java | 11 +-
.../broker/service/persistent/PersistentTopic.java | 78 ++---
.../buffer/impl/TopicTransactionBuffer.java | 1 -
.../apache/pulsar/broker/admin/BookiesApiTest.java | 58 +++-
.../broker/admin/CreateSubscriptionTest.java | 22 ++
.../broker/service/BacklogQuotaManagerTest.java | 2 +
.../broker/service/PersistentTopicE2ETest.java | 22 +-
.../pulsar/broker/service/PersistentTopicTest.java | 3 +-
.../pulsar/broker/transaction/TransactionTest.java | 26 ++
.../pulsar/compaction/CompactedTopicTest.java | 50 ++++
pulsar-client-cpp/CMakeLists.txt | 2 +-
.../pulsar/client/impl/ConsumerBuilderImpl.java | 86 +++---
.../apache/pulsar/client/impl/ConsumerImpl.java | 13 +-
.../pulsar/client/impl/schema/AbstractSchema.java | 7 +-
.../client/impl/transaction/TransactionImpl.java | 4 +-
.../org/apache/pulsar/client/impl/MessageTest.java | 13 +-
pulsar-io/debezium/postgres/pom.xml | 7 +
.../pulsar/sql/presto/PulsarRecordCursor.java | 202 +++++++------
.../impl/MLTransactionMetadataStore.java | 328 ++++++++++++---------
.../org/apache/pulsar/websocket/ReaderHandler.java | 10 +-
.../apache/pulsar/websocket/ReaderHandlerTest.java | 214 ++++++++++++++
.../offload/jcloud/impl/MockManagedLedger.java | 5 +
36 files changed, 991 insertions(+), 407 deletions(-)
create mode 100644
pulsar-websocket/src/test/java/org/apache/pulsar/websocket/ReaderHandlerTest.java
