Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Update dependency org.apache.pulsar:pulsar-client to v2.8.4 #34

Open
wants to merge 1 commit into
base: master
Choose a base branch
from
Open

Update dependency org.apache.pulsar:pulsar-client to v2.8.4 #34

wants to merge 1 commit into from

Conversation

mend-for-jackfan.us.kg[bot]
Copy link

This PR contains the following updates:

Package Type Update Change
org.apache.pulsar:pulsar-client compile minor 2.6.1 -> 2.8.4

By merging this PR, the issue #10 will be automatically resolved and closed:

Severity CVSS Score CVE Reachability
High High 8.6 CVE-2024-36114
Medium Medium 5.9 CVE-2022-33681

Release Notes

apache/pulsar (org.apache.pulsar:pulsar-client)

v2.8.4

Compare Source

Broker
  • [improve][broker] Do not print the log that the topic does not exist #​13535
  • [fix][broker] Fix NPE when nextValidLedger is null #​13975
  • [fix][broker] Fix NPE when ReplicatedSubscriptionsController sends marker message with deduplication enabled #​14017
  • [fix][broker] Fix avg-messagePerEntry metrics for consumer #​14330
  • [improve][broker] Validate rack name when setting the bookie rack info #​14336
  • [improve][broker] Optimize find nics process. #​14340
  • [fix][broker] Fix NPE when subscription is already removed #​14363
  • [fix][broker] Fix Broker HealthCheck Endpoint Exposes Race Conditions #​14367
  • [improve][broker] Optimize RawReader#create when using Compactor #​14447
  • [fix][broker] Fix the latest message of the compacted topic cannot be read #​14449
  • [fix][broker] Fix producerFuture not completed in ServerCnx#handleProducer #​14467
  • [fix][broker] Fix NPW in ManagedLedgerImpl #​14481
  • [improve][broker] Support shrink in ConcurrentLongHashMap #​14497
  • [fix][broker] Fixed wrong behaviour caused by not cleaning up topic policy service state. #​14503
  • [improve][broker] Optimize memory usage: support to shrink for pendingAcks map #​14515
  • [fix][broker] Cancel offload tasks when managed ledger closed #​14744
  • [improve][broker] Reduce unnecessary expansions for ConcurrentLong map and set #​14562
  • [fix][broker] Fix metadata store deadlock when checking BacklogQuota #​14634
  • [improve][broker] Support shrink for map or set #​14663
  • [fix][broker] Fix lost message issue due to ledger rollover #​14664
  • [fix][broker] Set splitNamespaceBundle with readonly=false #​14680
  • [fix][broker] Fixed duplicated delayed messages when all consumers disconnect #​14740
  • [fix][broker] Fix wrong state for non-durable cursor #​14869
  • [fix][broker] Improve error logging for topic not found #​14892
  • [fix][broker] Fix topic policy reader close bug #​14897
  • [fix][broker] Return if reset in progress #​14978
  • [fix][broker] Fix potential NPE in Replicator #​15003
  • [fix][broker] Fix race condition in updating lastMarkDeleteEntry field #​15031
  • [fix][broker] Fix potential to add duplicated consumer #​16826
  • [fix][broker] Follow up on race condition fixes in ManagedCursorImpl #​15031 #​15067
  • [cleanup] [broker] Remove useless code to avoid confusion in OpReadEntry#checkReadCompletion #​15104
  • [fix][broker] Cancel fencedTopicMonitoringTask when topic closed normally. #​15202
  • [fix][broker] Fix MessageDeduplication#inactiveProducers may not be persistence correctly #​15206
  • [fix][broker] Fix race condition between timeout and completion in OpAddEntry #​15233
  • [fix][broker] Fix problem at RateLimiter#tryAcquire #​15306
  • [improve][broker] Use shrink map for message redelivery. #​15342
  • [improve][broker] Support shrink for ConcurrentSortedLongPairSet #​15354
  • [improve][broker] Close connection if a ping or pong message cannot be sent #​15382
  • [cleanup][broker] Fix typo in enum name and handle closing of the channel properly since writeAndFlush is asynchronous #​15384
  • [fix][broker] Avoid heartbeat topic to offload. #​15393
  • [fix][broker] Fix deadlock in broker after race condition in topic creation failure #​15570
  • [fix][broker] fix calculation in getNumberOfEntriesInStorage #​15627
  • [fix][broker] Fix NPE when set AutoTopicCreationOverride #​15653
  • [fix][broker] Fix creating producer failure when set backlog quota #​15663
  • [fix][broker] Fix NPE when put value to RangeCache #​15707
  • [fix][broker] Fix can not enable system topic if AutoUpdateSchemaEnabled=false #​15759
  • [fix][broker] Fix wrong unit of NIC speed on Linux #​15770
  • [fix][broker] Fix NPE in MessageDeduplication #​15820
  • [fix][broker] Fix NPE when ledger id not found in OpReadEntry #​15837
  • [fix][broker] When skipping updating mark delete position, execute callback with executor to prevent deadlock #​15971
  • [fix][broker] Fix NPE when drop backlog for time limit. #​16235
  • [fix][broker]Fix getInternalStats occasional lack of LeaderInfo again #​16238
  • [fix][broker] Fix RawReader out of order #​16390
  • [fix][broker] Skip reading more entries for a pending read with no more entries #​16400
  • [fix][broker] Fix No such ledger exception #​16420
  • [fix][broker] Fix RawReader hasMessageAvailable returns true when no messages #​16443
  • [fix][broker] Fix stats-internal with option -m cause active ledger recover then close #​16662
  • [fix][broker] Fix passing incorrect authentication data #​16840
  • [fix][broker] ManagedCursor: mark delete no callback when create meta-ledger fail #​16841
  • [improve][broker] Avoid reconnection when a partitioned topic was created concurrently #​16867
  • [improve][broker] Recycle OpReadEntry in some corner cases #​16869
  • [fix][broker] Fix compaction subscription acknowledge Marker msg issue. #​16918
Security
  • [fix][sec] Use provider's canLookupAsync method for AuthorizationService #​11777
  • [improve][sec] Optimize the logic of allowing namespace operation #​13090
  • [improve][sec] Full-support set SSL provider, ciphers and protocols #​13740
  • [fix][sec] Role with namespace produce authz can also get topics #​13773
  • [improve][sec] Full-support SSL provider, ciphers, and protocols for broker service and proxy service #​15034
  • [improve][sec] Add load multiple certificates support #​14798
  • [fix][sec] Fix handling single role and non-jwt-token in MultiRolesTokenAuthorizationProvider #​14857
  • [fix][sec] Use tlsCertRefreshCheckDurationSec instead of 0 for refresh value #​15075
  • [improve][sec] Skip unnecessary DNS resolution when creating AuthenticationDataHttp instance #​15221
  • [improve][sec] Improve skipping of DNS resolution when creating AuthenticationDataHttp instance #​15228
  • [fix][sec] Fix MultiRolesTokenAuthorizationProvider authorize issue #​15454
  • [fix][sec] Fix grant all permissions but can't list topic #​15501
  • [improve][sec] Switch to rely on Netty for Hostname Verification #​15824
  • [fix][sec] Fix create client with TLS config #​16014
  • [fix][sec] Avoid AuthenticationDataSource mutation for subscription name #​16065
  • [improve][sec] Improve get the basic authentication config #​16526
  • [fix][sec] Fix multiple roles authorization #​16645
  • [fix][sec] Add timeout of sync methods and avoid call sync method for AuthoriationService (#​15694) #​16831
  • [improve][sec] Support for get token from HTTP params #​16871
  • [improve][sec] Adapt basic authentication configuration with prefix #​16935
Admin
  • [improve][admin] Add corresponding get command for namespace #​12322
  • [fix][admin] Fix deleting namespace will fail when system topics exist #​15040
  • [fix][admin] Fix validateGlobalNamespaceOwnership wrap exception issue #​14612
  • [fix][admin] Fix wrong prompt exception when getting the non-persistent topic list without GET_BUDNLE permission #​14638
  • [fix][admin] Fixed 404 error msg not returned correctly using http lookup #​14677
  • [improve][admin] Provide an accurate error message when set autoTopicCreation #​14684
  • [fix][admin] Fix cannot delete namespace with system topic #​14730
  • [fix][admin] Fix NPE in PulsarAdminBuilder when the service is not set #​14769
  • [fix][admin] Fix missing response type in swagger definitions #​16022
Function
  • [fix][fn] Fixing get functions for output topic and serde classname #​14103
  • [improve][fn] Pass configured metricsPort to k8s runtime #​14502
  • [fix][fn] fix some IOExceptions when create functions from package URL #​14553
  • [fix][fn] handle NPE when getLeader returns null #​15058
  • [improve][fn] Add KeyStore support in WebSocket, Function Worker HTTPS Servers #​15084
  • [fix][function] Check executor null when close the FileSource #​15247
  • [improve][fn] Provide default error handler for function log appender #​15728
  • [fix][function] Fix error when user starts with the pulsar functions local runner #​16565
  • [fix][function] Fix python instance not process zip file correctly #​16697
IO
  • [fix][io] throw exceptions when Kafka offset backing store failed to start #​14491
  • [fix][io] Handle Kafka sinks that return immutable maps as configs #​14780
SQL
  • [fix][sql] Fix PulsarRecordCursor deserialize issue. #​14615
  • [fix][sql] Fix messageQueue release message issue. #​16155
Offloader
  • [fix][offloader] Fix incorrect entryId in warn log when reading entry from tiered storage #​14685
  • [improve] TieredStorage: add debug information #​14907
  • [feat][offloader] Add pure S3 provider for the offloader #​15710
  • [fix][offloader] Fix setManagedLedgerOffloadedReadPriority not work. #​16436
Proxy
  • [improve][proxy] Log warning when opening connection to broker fails #​14710
  • [refactor][proxy] Refactor Proxy code and fix connection stalling by switching to auto read mode #​14713
  • [improve][proxy] Configure Netty DNS resolver to match JDK DNS caching setting, share DNS resolver instance in Proxy #​15219
  • [fix][proxy] Fix proxy connection leak when inbound connection closes while connecting is in progress #​15366
  • [fix][proxy] Fix DNS server denial-of-service issue when DNS entry expires #​15403
  • [improve][proxy] Remove unnecessary blocking DNS lookup in LookupProxyHandler #​15415
  • [fix][proxy] Do not preserve host when forwarding admin requests. #​16342
  • [fix][proxy] Fix client service URL #​16834
Monitor
  • [improve][monitor]: add metrics for pulsar web service thread pool #​14742
  • [improve][monitor] add message ack rate metric for consumer #​15674
  • [fix][monitor] Fix bug: fail to expose managed ledger client stats to prometheus if bookkeeperClientExposeStatsToPrometheus is true #​16343
  • [improve][monitor] Expose topic level storage write and read rate metrics #​16855
CLI
  • [fix][cli] Remove the trust certs check #​14764
Test & Other
  • [improve][test] Use Awaitility to replace Thread.sleep for pulsar-zookeeper-utils module. #​11017
  • [fix][test] Fix flaky test in PersistentStreamingDispatcherBlockConsumerTest #​12943
  • [fix][build] Fix NoClassDefFoundError: com/google/inject/AbstractModule in pulsar-io/batch-data-generator and Jcloud offloader #​14150
  • [fix][test] Fix flaky AdminApiSchemaTest#testSchemaInfoApi #​14508
  • [fix][test] Fix NamespacesTest execution order #​14552
  • [fix][test] Fix AdminApiTest.testNamespaceSplitBundleConcurrent #​14565
  • [fix][test] Fix flaky test MemoryLimitTest#testRejectMessages (#​14220) #​14628
  • [fix][ci] Upgrade zlib version to 1.2.12 #​14964
  • [improve][build] Ignore case when obfuscating passwords in configuration scripts #​15077
  • [fix][build] Fix LICENSE files for branch-2.8 #​15261
  • [Improve][doc] Add config of IO and acceptor threads in proxy #​15340
  • [improve][build] Configure DLog Bookie, Pulsar, and Admin clients via pass-through config #​15818
  • [improve][build] Allow pulsar_tool_env.sh PULSAR_MEM to be Overridden #​15868
  • [fix][test] TieredStorageConfigurationTests - clear system properties #​15957
  • [fix][doc] Update/fix Swagger Annotation for param: authoritative #​16222
  • [improve][test] Verify the authentication data in the authorization provider #​16900
Dependency Updates
Java Client
  • [improve][java] Improve consumer listener logic #​13273
  • [fix][java] Fix ConsumerBuilderImpl#subscribeAsync blocks calling thread #​14614
  • [fix][java] Fix partitionsAutoUpdateFuture never completes #​14625
  • [fix][java] Fix race condition in consumer redelivery #​14687
  • [improve][java] Process maxRedeliverCount is 0 of DeadLetterPolicy #​14706
  • [improve][java] Avoid timer task run before previous subscribe complete #​14818
  • [fix][java] Fix potentially unfinished CompletableFuture in doReconsumeLater #​14947
  • [fix][java] ConsumerBuilderImpl can not set null to deadLetterPolicy. #​14980
  • [improve][java] Add test to ensure the message order in listener callbacks #​15049
  • [fix][java] Fix performance regression with message listener #​15162
  • [fix][java] Fix wrong behavior of deduplication for key based batching #​15413
  • [improve][java] improve logic when ACK grouping tracker checks duplicated message id #​15465
  • [fix][java] Remove consumer when close consumer command is received #​15761
  • [fix][java] Fix conversion of TimestampMillisConversion has no effect when Jsr310Conversion is enabled #​15863
  • [fix][java] Remove producer when close producer command is received #​16028
  • [fix][java] Fix thread safety issue of LastCumulativeAck #​16072
  • [improve][java] Send CloseConsumer on client timeout #​16616
  • [fix][java] Fix ReconsumeLater will hang up if retryLetterProducer exception #​16655
  • [fix][java] Fix load trust certificate #​16789
  • [fix][java] Remove redundant check for chunked message TotalChunkMsgSize in ConsumerImpl #​16797
  • [fix][java] Forget to update memory usage when message is invalid #​16835
  • [fix][java] Fix PatternTopicsChangedListener blocked when topic removed #​16842
  • [fix][java] Fix MaxQueueSize semaphore release leak in createOpSendMsg #​16915
C++ Client
  • [improve][cpp] Expose getLastMessageId in the Reader API #​11723
  • [fix][cpp] Fix hasMessageAvailable returns wrong value for last message #​13883
  • [fix][cpp] Fix thread safety issue for multi topic consumer #​14380
  • [fix][cpp] Fix wrong unit of Access Token Response's expires_in field #​14554
  • [fix][cpp] Handle exception in creating socket when fd limit is reached #​14587
  • [cleanup][cpp] Add braces around initialization of subobject #​14735
  • [fix][cpp] Fix producer is never destructed until client is closed #​14797
  • [fix][cpp] Fix flaky tests about reference count #​14854
  • [fix][cpp] Fix segmentation fault when creating socket failed #​14834
  • [fix][cpp] Fix the race condition of connect timeout task #​14823
  • [fix][cpp] Fix send callback might not be invoked in key-based batching #​14898
  • [fix][cpp] Fix connection is not closed when broker closes the connection to proxy #​15009
  • [fix][cpp] Fix single message metadata not set correctly #​15072
  • [fix][cpp] Fix UnknownError might be returned for a partitioned producer #​15161
  • [improve][cpp] Remove the flaky and meaningless tests #​15271
  • [improve][cpp] Wait until event loop terminates when closing the Client #​15316
  • [fix][cpp] Avoid race condition causing double callback on close #​15508
  • [fix][cpp] Generate correct well-known OpenID configuration URL #​15928
  • [fix][cpp] Rename function name: pulsar_producer_configuration_set_crypto_failure_action #​16031
  • [cleanup][cpp] Clean up C++ client curl configuration #​16064
  • [fix][cpp] Fix the close of Client might stuck or return a wrong result #​16285
  • [improve][cpp] Fix flaky C++ ClientTest.testWrongListener #​16510
Python Client
  • [fix][python] Fix generated Python protobuf code not compatible with latest protobuf package #​15846
WebSocket Client
  • [fix][ws] Fix MultiTopicReader#getConsumer ClassCastException 15534

v2.8.3

Compare Source

Important Notices
  • Fix detecting number of NICs in EC2 #​14252. In the event that Pulsar cannot determine the NIC speed from the host, please set loadBalancerOverrideBrokerNicSpeedGbps.
  • Bump BookKeeper 4.14.3 12906
  • Add broker config isAllowAutoUpdateSchema 12786
Security
  • Upgrade Postgres driver to 42.2.25 to get rid of CVE-2022-21724 14119
  • Get rid of CVEs in Solr connector 13822
  • Get rid of CVEs in InfluxDB connector 13821
  • Get rid of CVEs in batch-data-generator 13820
  • Get rid of CVEs brought in with aerospike 13819
  • [owasp] suppress false positive Avro CVE-2021-43045 13764
  • Upgrade protobuf to 3.16.1 to address CVE-2021-22569 13695
  • Upgrade Jackson to 2.12.6 13694
  • Upgrade Log4j to 2.17.1 to address CVE-2021-44832 13552
  • Cipher params not work in KeyStoreSSLContext 13322
  • [Broker] Remove tenant permission verification when list partitioned-topic 13138
  • Use JDK default security provider when Conscrypt isn't available 12938
  • [Authorization] Return if namespace policies are read only 12514
Pulsar Admin
  • Make sure policies.is_allow_auto_update_schema not null 14409
  • pulsar admin exposes secret for source and sink 13059
  • Fix deleting tenants with active namespaces with 500. 13020
  • [function] pulsar admin exposes secrets for function 12950
Bookkeeper
  • Upgrade BK to 4.14.4 and Grpc to 1.42.1 13714
  • Bump BookKeeper 4.14.3 12906
Broker
  • Fix the wrong parameter in the log. 14309
  • Fix batch ack count is negative issue. 14288
  • bug fix: IllegalArgumentException: Invalid period 0.0 to calculate rate 14280
  • Clean up individually deleted messages before the mark-delete position 14261
  • If mark-delete operation fails, mark the cursor as "dirty" 14256
  • Fixed detecting number of NICs in EC2 14252
  • Remove log unacked msg. 14246
  • Change broker producer fence log level 14196
  • Fix NPE of cumulative ack mode and incorrect unack message count 14021
  • KeyShared stickyHashRange subscription: prevent stuck subscription in case of consumer restart 14014
  • Trim configuration value string which contains blank prefix or suffix 13984
  • waitingCursors potential heap memory leak 13939
  • Fix read schema compatibility strategy priority 13938
  • NPE when get isAllowAutoUploadSchema 13831
  • Fix call sync method in async rest API for internalGetSubscriptionsForNonPartitionedTopic 13745
  • Fix the deadlock while using zookeeper thread to create ledger 13744
  • Fix inefficient forEach loop 13742
  • [Issue 13640] Fix non persistent topic subscription error. 13685
  • Fix invalid rack name cause bookie join rack failed 13683
  • Avoid call sync method in async rest API for force delete subscription 13668
  • Avoid call sync method in async rest API for delete subscription 13666
  • Fix getInternalStats occasional lack of LeaderInfo 13656
  • Fix reader skipped remaining compacted data during the topic unloading. 13629
  • [Issue 13479] Fixed internal topic effect by InactiveTopicPolicy. 13611
  • Fix bug :Infinity value for CPU or Bandwidth usage 13609
  • Change ContextClassLoader to NarClassLoader in BrokerInterceptor 13589
  • Fix NPE when unloading namespace bundle 13571
  • update log content 13540
  • Return message ID from compacted ledger while the compaction cursor reach the end of the topic 13533
  • Change ContextClassLoader to NarClassLoader in AdditionalServlet 13501
  • fix(Auth): Fix multi roles authz cannot handle empty roles case 13477
  • Fix getting the last message-id from an empty compact ledger 13476
  • Fixes the NPE in system topics policies service 13469
  • Fix race conditions in closing producers and consumers 13428
  • Fix batch message ack does not decrease the unacked-msg count. 13383
  • [Issue 13194][pulsar-broker] Fix dead loop in BacklogQuotaManager.dropBacklogForTimeLimit 13249
  • Modify return result of NamespacesBase#internalGetPublishRate 13237
  • Optimize ManagedLedger Ledger Ownership Check 13222
  • Close old compacted ledger when open new. 13210
  • fix shedding heartbeat ns 13208
  • Fix when deleting topic with NotFoundException, do not return to client. 13203
  • Update cursor last active timestamp when reseting cursor 13166
  • Remove tenant permission verification when list partitioned-topic 13138
  • Use current resourceUsage value as historyUsage when leader change in ThresholdShedder 13136
  • Don't attempt to delete pending ack store unless transactions are enabled 13041
  • Fix NPE in PersistentTopic.checkSubscriptionTypesEnable 12961
  • Fix wrong isEmpty method of ConcurrentOpenLongPairRangeSet 12953
  • Correct param of delete method for v1 topic 12936
  • Clean up the metadata of the non-persistent partitioned topics. 12910
  • Fix topic policy listener deleted by mistake. 12904
  • Fix deleting tenants with active namespaces with 500. 12848
  • [Issue 12757] add broker config isAllowAutoUpdateSchema 12786
  • Remove unused listeners if it have no listeners. 12654
  • Clean up the metadata of the non-persistent partitioned topics. 12550
  • [managedledger] NPE on OpAddEntry while ManagedLedger is closing 12364
  • fix issues 11964, deadlock bug when use key_shared mode 11965
Build
  • [C++] Fix GCC compilation failure caused by warning macro 14402
  • [C++] Fix Version.h not found when CMake binary directory is customized 13324
  • [Issue 9888] add python3.9 on manylinux2014 build support 10954
C++ Client
  • Fix GCC compilation failure caused by warning macro 14402
  • Fix pulsar client cpp build fail in gcc-4.8.5 14053
  • Fix hasMessageAvailable returns wrong value for last message 13883
  • Fix Version.h not found when CMake binary directory is customized 13324
  • Fix in macOS CMake might find error boost-python libs path 13193
CI
  • Upgrade Windows runner os to windows-2022 and generator 14368
  • Replace deprecated "adopt" OpenJDK distribution with "temurin" in GitHub Actions config 12945
Pulsar CLI
  • Feat(cli): support autorecovery service in pulsar cli 12985
  • [pulsar-perf] Write histogram files for consume command 12569
Java Client
  • Fix adding message to list potential issue 14377
  • Fix send to deadLetterTopic not working when reach maxRedeliverCount 14317
  • Fix time unit mismatch in errMsg when producer send fails. 14299
  • Fix PersistentAcknowledgmentsGroupingTracker set BitSet issue. 14260
  • Check getTlsTrustStorePath NPE when user forget to set it. 14253
  • [Issue 12262] Fix consume failure when BatchReceivePolicy#maxNumBytes < message size 14139
  • Use scheduleWithFixedDelay instead of scheduleAtFixedRate for java producer batch timer 14125
  • Add a default timeout for OAuth2 Metadata Resolver 14056
  • Fix send chunking message failed when ordering key is set. 13699
  • Fixed Producer semaphore permit release issue 13682
  • Fix the wrong multi-topic has message available behavior 13634
  • Use PulsarByteBufAllocator to allocate buffer for chunks 13536
  • Fix resources leak when create producer failed 13505
  • Fix semaphore and memory leak when chunks failed to enqueue 13454
  • Fix invalid setting of enabled ciphers to fix warning from BoringSSL 13435
  • [Producer] Change the time units from ns to ms 13057
  • Fix consume message order issue when use listener. 13023
  • Use sendAsync instead of send when produce message to retry topic. 12946
  • [Java Client] Avoid IllegalStateException in ClientCnx debug logs 12899
  • [pulsar-client] Add conf backoff values 12520
  • Add log error tracking for semaphore count leak 12410
Compaction
  • Fix reader skipped remaining compacted data during the topic unloading. 13629
  • Return message ID from compacted ledger while the compaction cursor reach the end of the topic 13533
  • [Broker] Fix getting the last message-id from an empty compact ledger 13476
Functions
  • Fix(functions): missing runtime set in GoInstanceConfig 13031
  • [function] pulsar admin exposes secrets for function 12950
Pulsar IO
  • Pulsar admin exposes secret for source and sink 13059
  • Pass client builder if no service url provided to debezium connector 12145
  • [Cherry-pick] Pass client builder to debezium database history 12112
  • Pass client builder if no service url provided to debezium connector 14040
Key-Shared Subscription
  • [Issue 12885] Fix unordered consuming case in Key_Shared subscription. 12890
Pulsar Metadata
  • AbstractMetadataStore: invalidate childrenCache correctly when node created 14177
Metrics
  • Fix: bug when allAll bucket 13467
Pulsar proxy
  • Fix port exhaustion and connection issues in Pulsar Proxy 14078
  • Allow config of IO and acceptor threads in proxy 14054
  • Remove unnecessary Pulsar Client usage from Pulsar Proxy 13836
Python Client
  • Apply clang-format check for python wrapper 13418
Schema
  • Fix parse BigDecimal 14019
  • Fix pulsar use json or avro primitive schema. 12886
SQL
  • Support protobuf/timestamp 13287
  • Fix time field use error 12249
Test
  • Improved 9 flaky tests.
Tools
  • Fix NPE in cmdTopics 13450
  • [pulsar-perf] Support listenerThreads configuration. 12892
  • [docs] Fix doc for pulsar-admin bookies cmd 12542
Topic policy
  • [Broker] Avoid thread deadlock problem when creating topic policy reader 13837
  • Fixed internal topic effect by InactiveTopicPolicy. 13816
Transaction
  • Fix topicTransactionBuffer handle null snapshot (#​12758) 14510
  • Fix transaction system topic create in loop 12889
  • Fix transaction system topic create in loop. 12749
Websocket
  • Fix ClassCastException when user create MultiTopicReader. 14316
Dependency
  • Upgrade Gson version 2.8.6 to 2.8.9 13610
  • Upgrade commons-cli to 1.5.0 14094
  • Bump netty version to 4.1.74.Final 14257

v2.8.2

Compare Source

Security
Broker
  • Fix and improve topic ownership assignment #​13069
  • Fix LeaderElectionService.getCurrentLeader and add support for empheralOwner in MockZooKeeper #​13066
  • Do not reuse the Failed OpAddEntry object which leads to the bundle unloading timeout. #​12993
  • Remove readerCaches and close reader when exception occurs in SystemTopicBasedTopicPoliciesService #​12873
  • Fix TopicPoliciesCacheNotInitException issue. #​12773
  • Support UNSUBSCRIBE namespace op after enabling auth #​12742
  • Fix race condition in PersistentTopic#addReplicationCluster #​12729
  • Even if always compatible is set, consumers cannot be created #​12721
  • Fix the incorrect total size when BrokerEntryMetadata is enabled #​12714
  • Fix lost compaction data due to compaction properties missed during reset-cursor #​12698
  • Fix TestRunMain test #​12675
  • Support GET_METADATA topic op after enabling auth #​12656
  • Fix false positive ownership check in OwnershipCache#checkOwnership #​12650
  • Optimize exception information for schemas #​12647
  • Add @​Test annotation to test methods #​12640
  • Support retry when creating reader of Topic Policies #​12622
  • Fix String should use equals but not ==. #​12619
  • Fix 12614, waitingForPingResponse needs to be modified with volatile for concurrent sence #​12615
  • Cleanup ProxyPublishConsumeTest #​12607
  • Avoid passing OpAddEntry across a thread boundary in asyncAddEntry #​12606
  • Do not move the non-durable cursor position when trimming ledgers while topic with compaction #​12602
  • Allow GetTopicsOfNamespace op with consume permission #​12600
  • Allow configuring schema compatibility policy for system topics #​12598
  • Cleanup already deleted namespace topics. #​12597
  • Fix additional servlets NAR might extract to null directory #​12585
  • Fix log typo in NamespaceService#checkHeartbeatNamespace #​12582
  • Add OpAddEntry to pendingAddEntries after the state check #​12570
  • Cancel scheduled tasks when deleting ManagedLedgerImpl #​12565
  • Add git branch information for PulsarVersion #​12541
  • Websocket should pass the encryption context to consumers #​12539
  • The count of topics on the bundle is less than 2，skip split #​12527
  • Fix the reader skips compacted data which original ledger been removed #​12522
  • Fix messageDedup delete inactive producer name #​12493
  • Optimize the code: remove extra spaces #​12470
  • Future completed twice in the method of impl.MLPendingAckStore#closeAsync #​12362
  • Fix the race of delete subscription and delete topic #​12240
  • Disable stats recorder for built-in PulsarClient #​12217
  • Fix delete authentication policies when deleting topics. #​12215
  • Optimize the memory usage of Cache Eviction #​12045
  • Avoid adding duplicated BrokerEntryMetadata #​12018
  • Fix update ledger list to znode version mismatch failed, ledger not delete #​12015
  • Fix messages in TopicPolicies will never be cleaned up #​11928
  • Fix returned wrong hash ranges for the consumer with the same consumer name #​12212
  • Add Key_Shared metadata to topic stats #​11839
  • Fix build from submodules (broker, transaction coordinator) #​11795
  • Add method to clear up transaction buffer snapshot #​11934
  • Increase the test stability of transactionTest #​11541
  • Add maven.restlet.org repository #​13248
  • Fix and improve topic ownership assignment (#​13069) #​13117
  • Evaluate the current protocol version once #​13045
  • Revert "Set default root log level to debug" and make PULSAR_LOG_ROOT_LEVEL default to PULSAR_LOG_LEVEL #​12941
  • Catch exceptions in scheduled tasks to prevent unintended cancellation #​12853
  • Fix producer getting incorrectly removed from topic's producers map #​12846
  • Synchronize updates to the inactiveProducers map in MessageD… #​12820
  • Close connection after receiving unexpected SendCommand #​12780
  • Fix namespace policy override ignored when creating subscription #​12699
  • Update lombok to 1.18.22 #​12466
  • Fix skips compacted data for reader/consumer #​12464
  • Remove data race in MultiTopicsConsumerImpl to ensure correct message order #​12456
  • Fix the retry topic's REAL_TOPIC & ORIGIN_MESSAGE_ID property #​12451
  • Change the producer fence error log to debug level #​12447
  • Reduce the readFailureBackoff time #​12444
  • Fix wrong property name in NamespaceIsolationDataImpl#secondary #​12433
  • Optimize SecurityUtility code flow #​12431
  • Fix compactor skips data from last compacted Ledger #​12429
  • Remove redundant code #​12424
  • Fix some tests not enabled in integration tests #​12417
  • Use weak ref to ClientConnection for timeout task #​12409
  • Fix cherry-pick issue #​12397
  • Fix the null point caused by deleting the system topic policy #​12367
  • Update delete inactive topic configuration documentation #​12350
  • Add log to print exception stack. #​12345
  • Avoid potentially blocking calls to metadata on critical threads #​12339
  • Fix NPE when removing cursor #​12297
  • Print log when configuration is failed to load #​12280
  • Fix incorrect returned last message ID while the lastConfirmedEntry w

@mend-for-jackfan.us.kg mend-for-jackfan.us.kg bot added the security fix Security fix generated by Mend label Feb 24, 2025
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Reviewers
No reviews
Assignees
No one assigned
Labels
security fix Security fix generated by Mend
Projects
None yet
Milestone
No milestone
Development

Successfully merging this pull request may close these issues.
0 participants