momo-jun commented on code in PR #167: URL: https://github.com/apache/pulsar-site/pull/167#discussion_r949877102
########## site2/website-next/release-notes/versioned/pulsar-2.11.0.md: ########## @@ -0,0 +1,497 @@ +--- +id: pulsar-2.11.0 +title: Apache Pulsar 2.11.0 +sidebar_label: Apache Pulsar 2.11.0 +--- + +#### 2022-08-16 + +### Important notice +- Rename Pulsar txn metrics to specify OpenMetrics [#16581](https://github.com/apache/pulsar/pull/16581) +- Rename Pulsar schema metrics to specify OpenMetrics [#16610](https://github.com/apache/pulsar/pull/16610) +- Rename Pulsar lb metrics to specify OpenMetrics [#16611](https://github.com/apache/pulsar/pull/16611) +- Remove jul-to-slf4j #16320 [#16320](https://github.com/apache/pulsar/pull/16320) +- Fix get non-persistent topics issue in Namespaces [#16170](https://github.com/apache/pulsar/pull/16170) +- Fix producer/consume permission can’t get schema [#15956](https://github.com/apache/pulsar/pull/15956) +- Add verification for configured default backlog quota and retention [#15441](https://github.com/apache/pulsar/pull/15441) +- Fix broker LoadBalance uneffective [#15314](https://github.com/apache/pulsar/pull/15314) +- Ensure the deletion consistency of topic and schema [#14608](https://github.com/apache/pulsar/pull/14608) +- Transaction cumulative ack redeliver change [#14371](https://github.com/apache/pulsar/pull/14371) +- Bump prometheus client version from 0.5.0 to 0.15.0 [#13785](https://github.com/apache/pulsar/pull/13785) +- [PIP-158] Split client TLS transport encryption from authentication [#15634](https://github.com/apache/pulsar/pull/15634) +- [PIP-155] Removed Python 2 support [#15376](https://github.com/apache/pulsar/pull/15376) +- [PIP-156] Build Pulsar Server on Java 17 [#15264](https://github.com/apache/pulsar/pull/15264) +- [PIP-162] Enable system topic by default [#15619](https://github.com/apache/pulsar/pull/15619) +- [PIP-174] New managed ledger entry cache implementation [#15955](https://github.com/apache/pulsar/pull/15955) + +### PIPs +- [PIP 37] Support chunking with Shared subscription [#16202](https://github.com/apache/pulsar/pull/16202) +- [PIP-74] Pulsar client memory limits [#14400](https://github.com/apache/pulsar/pull/14400) +- [PIP-81] Split createNewMetadataLedger into multiple methods for reuse [#15425](https://github.com/apache/pulsar/pull/15425) +- [PIP 97] Update Authentication Interfaces to Include Async Authentication Methods [#12104](https://github.com/apache/pulsar/pull/12104) +- [PIP-100] Support pluggable topic factory [#12235](https://github.com/apache/pulsar/pull/12235) +- [PIP-105] Store Subscription properties [#15757](https://github.com/apache/pulsar/pull/15757) +- [PIP-117] Change Pulsar standalone defaults [#15478](https://github.com/apache/pulsar/pull/15478) +- [PIP-132] Include message header size when check maxMessageSize for non-batch message on the client side. [#14007](https://github.com/apache/pulsar/pull/14007) +- [PIP-136] Sync Pulsar metadata across multiple clouds [#16425](https://github.com/apache/pulsar/pull/16425) +- [PIP-143] Support split bundle by specified boundaries [#13796](https://github.com/apache/pulsar/pull/13796) +- [PIP-145] Improve performance of regex subscriptions [#14505](https://github.com/apache/pulsar/pull/14505) +- [PIP-146] ManagedCursorInfo compression [#14542](https://github.com/apache/pulsar/pull/14542) +- [PIP 149] Making the REST Admin API fully async [#14365](https://github.com/apache/pulsar/issues/14365) +- [PIP-152] Support subscription level dispatch rate limiter setting [#15295](https://github.com/apache/pulsar/issues/15295) +- [PIP-153] Optimize metadataPositions in MLPendingAckStore [#15137](https://github.com/apache/pulsar/pull/15137) +- [PIP-160] Make transactions work more efficiently by aggregation operation for transaction log and pending ack store [#15370](https://github.com/apache/pulsar/issues/15370) +- [PIP-161] Exclusive Producer: ability to fence out an existing Producer [#15488](https://github.com/apache/pulsar/pull/15488) +- [PIP-163] Add lowWaterMark check before appending entry to TB [#15424](https://github.com/apache/pulsar/pull/15424) +- [PIP-166] Function add MANUAL delivery semantics [#16279](https://github.com/apache/pulsar/pull/16279) +- [PIP-179] Support the admin API to check unknown request parameters [#16135](https://github.com/apache/pulsar/issues/16135) +- [PIP-181] Pulsar Shell [#16250](https://github.com/apache/pulsar/issues/16250) +- [PIP-184] Topic specific consumer priorityLevel [#16715](https://github.com/apache/pulsar/issues/16715) +- [PIP-187] Add API to analyze a subscription backlog and provide a accurate value [#16545](https://github.com/apache/pulsar/issues/16545) + +### Broker +- [PIP 81] Split the individual acknowledgments into multiple entries + - Add range set wrapper to support record dirty ledgers [#15607](https://github.com/apache/pulsar/pull/15607) + - Notifications for faster topic discovery [#16062](https://github.com/apache/pulsar/pull/16062) + - Split createNewMetadataLedger into multiple methods for reuse [#15425](https://github.com/apache/pulsar/pull/15425) +- [PIP 105] Store Subscription properties + - Store Subscription properties [#15757](https://github.com/apache/pulsar/pull/15757) + - Pulsar Admin: create subscription with Properties [#15503](https://github.com/apache/pulsar/pull/15503) + - Fix error on recycled SubscriptionPropertiesList [#15335](https://github.com/apache/pulsar/pull/15335) +- [PIP 160] Make transactions work more efficiently by aggregation operation for transaction log and pending ack store + - Pending ack log store enables the batch feature [#16707](https://github.com/apache/pulsar/pull/16707) + - Metrics stats of Transaction buffered writer [#16758](https://github.com/apache/pulsar/pull/16758) + - Transaction buffered writer supports Timer [#16727](https://github.com/apache/pulsar/pull/16727) + - Transaction log store enables the batch feature [#16685](https://github.com/apache/pulsar/pull/16685) + - Protocol changes and configuration changes for transaction batch log [#16617](https://github.com/apache/pulsar/pull/16617) + - Txn buffered writer for transaction log batch [#16428](https://github.com/apache/pulsar/pull/16428) +- [PIP 145] Improve performance of regex subscriptions + - Enable evaluating subscription pattern on broker side [#14804](https://github.com/apache/pulsar/pull/14804) + - Notifications for faster topic discovery [#16062](https://github.com/apache/pulsar/pull/16062) +- [PIP-156] Build Pulsar Server on Java 17 + - Build changes by dropping some required checks [#15496](https://github.com/apache/pulsar/pull/15496) + - Build Pulsar Server on Java 17 [#15264](https://github.com/apache/pulsar/pull/15264) +- Optimize getting ledger and entry id from entry [#17108](https://github.com/apache/pulsar/pull/17108) +- Pass subscriptionName to auth service [#17123](https://github.com/apache/pulsar/pull/17123) +- Support loadBalancerSheddingIntervalMinutes dynamic configuration [#16408](https://github.com/apache/pulsar/pull/16408) +- Fix out of order data replication [#17154](https://github.com/apache/pulsar/pull/17154) +- Fix schema does not replicate successfully [#17049](https://github.com/apache/pulsar/pull/17049) +- Streaming dispatcher stuck after reading the first entry with SHARED subscriptions [#17143](https://github.com/apache/pulsar/pull/17143) +- Fix calculate avg message per entry [#17046](https://github.com/apache/pulsar/pull/17046) +- Bundle-data metadata leak because of bundlestats was not clean [#17095](https://github.com/apache/pulsar/pull/17095) +- Duplicate ByteBuffer when Caching Backlogged Consumers [#17105](https://github.com/apache/pulsar/pull/17105) +- Fix offload read handle NPE [#17056](https://github.com/apache/pulsar/pull/17056) +- Move the state check forward [#17020](https://github.com/apache/pulsar/pull/17020) +- Improve naming for delete topic error [#16965](https://github.com/apache/pulsar/pull/16965) +- Increment topic stats outbound message counters and update rate after messages have been written to the TCP/IP connection [#17043](https://github.com/apache/pulsar/pull/17043) +- Prevent StackOverFlowException in SHARED subscription [#16968](https://github.com/apache/pulsar/pull/16968) +- Improve the package download process [#16365](https://github.com/apache/pulsar/pull/16365) +- Skip mis-configured resource usage(>100%) in load balancer [#16937](https://github.com/apache/pulsar/pull/16937) +- Not allow to terminate system topic [#17006](https://github.com/apache/pulsar/pull/17006) +- Follow up on #16968 to restore some behavior in PersistentDispatcherMultipleConsumers [#17018](https://github.com/apache/pulsar/pull/17018) +- Remove exception log when access status.html [#17025](https://github.com/apache/pulsar/pull/17025) +- Remove unnecessary lock on the stats thread [#16983](https://github.com/apache/pulsar/pull/16983) +- Fix memory leak if entry exists in cache [#16996](https://github.com/apache/pulsar/pull/16996) +- Fix ConcurrentModificationException when ModularLoadManagerImpl start [#16953](https://github.com/apache/pulsar/pull/16953) +- Split TLS transport encryption support from authentication [#16819](https://github.com/apache/pulsar/pull/16819) +- Support start multiple bookies for BKCluster [#16847](https://github.com/apache/pulsar/pull/16847) +- Fix MaxQueueSize semaphore release leak in createOpSendMsg [#16915](https://github.com/apache/pulsar/pull/16915) +- PulsarLedgerManager to pass correct error code to BK client [#16857](https://github.com/apache/pulsar/pull/16857) +- Improve get the basic authentication config [#16526](https://github.com/apache/pulsar/pull/16526) +- Change delete pending ack position from foreach to firstKey [#16927](https://github.com/apache/pulsar/pull/16927) +- Adapt basic authentication configuration with prefix [#16935](https://github.com/apache/pulsar/pull/16935) +- Fix misleading -c option in pulsar standalone [#16838](https://github.com/apache/pulsar/pull/16838) +- Fix rack awareness cache expiration data race [#16825](https://github.com/apache/pulsar/pull/16825) +- Fix Repeated messages of shared dispatcher [#16812](https://github.com/apache/pulsar/pull/16812) +- Avoid IllegalStateException while client_version is not set [#16788](https://github.com/apache/pulsar/pull/16788) +- Optimize concurrent collection's shrink logic [#16754](https://github.com/apache/pulsar/pull/16754) +- Support clear old bookie data for BKCluster [#16744](https://github.com/apache/pulsar/pull/16744) +- Fix consumer does not abide by the max unacks limitation for Key_Shared subscription [#16718](https://github.com/apache/pulsar/pull/16718) +- Avoid ConcurrentModificationException for ModularLoadManagerImpl.cleanupDeadBrokersData() [#16690](https://github.com/apache/pulsar/pull/16690) +- Retry to delete the namespace if new topics created during the namespace deletion [#16676](https://github.com/apache/pulsar/pull/16676) +- Fix consumer does not abide by the max unacks limitation for Shared subscription [#16670](https://github.com/apache/pulsar/pull/16670) +- Support for get token from HTTP params [#16650](https://github.com/apache/pulsar/pull/16650) +- Make defaultOffloader create after offloaderStats overrides [#16638](https://github.com/apache/pulsar/pull/16638) +- BadVersionException when splitting bundles, delay 100ms and try again [#16612](https://github.com/apache/pulsar/pull/16612) +- PulsarLedgerManager: add missed return statement [#16607](https://github.com/apache/pulsar/pull/16607) +- The configuration loadBalancerNamespaceMaximumBundles is invalid [#16552](https://github.com/apache/pulsar/pull/16552) +- Retry when DistributedIdGenerator has BadVersion error [#16491](https://github.com/apache/pulsar/pull/16491) +- Fixed error when delayed messages trackers state grows to >1.5GB [#16490](https://github.com/apache/pulsar/pull/16490) +- Fix RawReader hasMessageAvailable returns true when no messages [#16443](https://github.com/apache/pulsar/pull/16443) +- Fix No such ledger exception [#16420](https://github.com/apache/pulsar/pull/16420) +- Add config maxUnloadBundleNumPerShedding for UniformLoadShedder [#16409](https://github.com/apache/pulsar/pull/16409) +- Fix etcd cluster error and add test for etcd cluster [#16309](https://github.com/apache/pulsar/pull/16309) +- Skip reading more entries for a pending read with no more entries [#16400](https://github.com/apache/pulsar/pull/16400) +- Recycle OpReadEntry in some corner cases [#16399](https://github.com/apache/pulsar/pull/16399) +- Add dynamic configuration for UniformLoadShedder [#16391](https://github.com/apache/pulsar/pull/16391) +- Fix RawReader out of order [#16390](https://github.com/apache/pulsar/pull/16390) +- Create the cursor ledger lazily to improve the subscribe performance [#16389](https://github.com/apache/pulsar/pull/16389) +- Release the entry in getEarliestMessagePublishTimeOfPos [#16386](https://github.com/apache/pulsar/pull/16386) +- Update cpu ResourceUsage before updating SystemResourceUsage usage [#16366](https://github.com/apache/pulsar/pull/16366) +- Use shared broker client scheduled executor provider [#16338](https://github.com/apache/pulsar/pull/16338) +- Do not use IO thread for consumerFlow in Shared subscription [#16304](https://github.com/apache/pulsar/pull/16304) +- Provide new load balance placement strategy implementation based on the least resource usage with weight [#16281](https://github.com/apache/pulsar/pull/16281) +- Fix TopicTransactionBuffer ledger apend marker throw ManagedLedgerAlreadyClosedException [#16265](https://github.com/apache/pulsar/pull/16265) +- Avoid go through all the consumers to get the message ack owner [#16245](https://github.com/apache/pulsar/pull/16245) +- Reduce the consumers list sort by priority level [#16243](https://github.com/apache/pulsar/pull/16243) +- Reduce the re-schedule message read operation for PersistentDispatcherMultipleConsumers [#16241](https://github.com/apache/pulsar/pull/16241) +- Fix npe when invoke replaceBookie. [#16239](https://github.com/apache/pulsar/pull/16239) +- Fix getInternalStats occasional lack of LeaderInfo again [#16238](https://github.com/apache/pulsar/pull/16238) +- Fix NPE when drop backlog for time limit [#16235](https://github.com/apache/pulsar/pull/16235) +- Improve error msg when client is unauthorized [#16224](https://github.com/apache/pulsar/pull/16224) +- Fix compaction subscription acknowledge Marker msg issue [#16205](https://github.com/apache/pulsar/pull/16205) +- Fix subscribe dispatcher limiter not be initialized [#16175](https://github.com/apache/pulsar/pull/16175) +- Use LinkedHashSet for config items of type Set to preserve elements order [#16138](https://github.com/apache/pulsar/pull/16138) +- Fix topic dispatch rate limiter not init on broker-level [#16084](https://github.com/apache/pulsar/pull/16084) +- Fix NPE when get /admin/v2/namespaces/public/default/maxTopicsPerNamespace [#16076](https://github.com/apache/pulsar/pull/16076) +- Add config to allow deliverAt time to be strictly honored [#16068](https://github.com/apache/pulsar/pull/16068) +- Add switch for enable/disable distribute bundles evenly in LoadManager [#16059](https://github.com/apache/pulsar/pull/16059) +- Fix thread safety issues in accessing ManagedCursorContainer.heap ArrayList [#16049](https://github.com/apache/pulsar/pull/16049) +- Make invalid namespace and topic name logs more descriptive [#16047](https://github.com/apache/pulsar/pull/16047) +- Terminate JVM when initialize-cluster-metadata command fails [#16039](https://github.com/apache/pulsar/pull/16039) +- Avoid storing MessageMetadata instances returned by peekMessageMetadata [#15983](https://github.com/apache/pulsar/pull/15983) +- Fix topic policies update not check message expiry [#15941](https://github.com/apache/pulsar/pull/15941) +- Fix reach max tenants error if the tenant already exists [#15932](https://github.com/apache/pulsar/pull/15932) +- Close transactionBufferClient before closing the internal Pulsar client [#15922](https://github.com/apache/pulsar/pull/15922) +- Remove topic -> namespace cache of LedgerOffloaderStatsImpl [#15869](https://github.com/apache/pulsar/pull/15869) +- Fix NPE when ledger id not found in OpReadEntry [#15837](https://github.com/apache/pulsar/pull/15837) +- Fix topic-level replicator rate limiter not init [#15825](https://github.com/apache/pulsar/pull/15825) +- Fix NPE in MessageDeduplication [#15820](https://github.com/apache/pulsar/pull/15820) +- Configure DLog Bookie, Pulsar, and Admin clients via pass through config [#15818](https://github.com/apache/pulsar/pull/15818) +- Fix the broker close hanged issue [#15755](https://github.com/apache/pulsar/pull/15755) +- Disable memory limit controller in internal Pulsar clients [#15752](https://github.com/apache/pulsar/pull/15752) +- Add timeout for unload namespace bundle [#15719](https://github.com/apache/pulsar/pull/15719) +- Support schemaValidationEnforced on topic level [#15712](https://github.com/apache/pulsar/pull/15712) +- Fix NPE when put value to RangeCache [#15707](https://github.com/apache/pulsar/pull/15707) +- Fast return if ack cumulative illegal [#15695](https://github.com/apache/pulsar/pull/15695) +- Fix creating producer failure when set backlog quota [#15663](https://github.com/apache/pulsar/pull/15663) +- Fix logging in shutdown when broker shutdown [#15626](https://github.com/apache/pulsar/pull/15626) +- Fix MetadataStoreException$NotFoundException while doing topic lookup [#15633](https://github.com/apache/pulsar/pull/15633) +- Use dispatchRateLimiterLock to update dispatchRateLimiter [#15601](https://github.com/apache/pulsar/pull/15601) +- Add .yaml suffix support for broker filter config file [#15600](https://github.com/apache/pulsar/pull/15600) +- Added newline to end of standalone.conf [#15591](https://github.com/apache/pulsar/pull/15591) +- Add decode InputStream for Schema [#16659](https://github.com/apache/pulsar/pull/16659) +- Create "standalone" cluster when starting standalone server [#15583](https://github.com/apache/pulsar/pull/15583) +- Close publishLimiter when disable it [#15520](https://github.com/apache/pulsar/pull/15520) +- Enable SO_REUSEADDR on listen sockets for broker,proxy [#15517](https://github.com/apache/pulsar/pull/15517) +- Fix to avoid TopicStatsImpl NPE even if producerName is null [#15502](https://github.com/apache/pulsar/pull/15502) +- Close connection if a ping or pong message cannot be sent [#15382](https://github.com/apache/pulsar/pull/15382) +- Introduce BitRateUnit for calculate bitrate [#15435](https://github.com/apache/pulsar/pull/15435) +- Add verification for configured default backlog quota and retention [#15441](https://github.com/apache/pulsar/pull/15441) +- Change unnecessary atomic to basic type [#15369](https://github.com/apache/pulsar/pull/15369) +- Support shrink for ConcurrentSortedLongPairSet [#15354](https://github.com/apache/pulsar/pull/15354) +- Use shrink map for message redelivery [#15342](https://github.com/apache/pulsar/pull/15342) +- Fix precision error in UsageUnit [#15322](https://github.com/apache/pulsar/pull/15322) +- Optimized namespace-level dispatcherRateLimiter update [#15315](https://github.com/apache/pulsar/pull/15315) +- Fix broker LoadBalance uneffective [#15314](https://github.com/apache/pulsar/pull/15314) +- Fix wrong unit of NIC speed on linux [#15304](https://github.com/apache/pulsar/pull/15304) +- Fix totalEntries calculation problem in AbstractBaseDispatcher#filterEntriesForConsumere [#15298](https://github.com/apache/pulsar/pull/15298) +- Fix resource group does not report usage [#15292](https://github.com/apache/pulsar/pull/15292) +- Tidy up the system topic [#15252](https://github.com/apache/pulsar/pull/15252) +- Fix race condition between timeout and completion in OpAddEntry [#15233](https://github.com/apache/pulsar/pull/15233) +- Improve skipping of DNS resolution when creating AuthenticationDataHttp instance [#15228](https://github.com/apache/pulsar/pull/15228) +- Skip unnecessary DNS resolution when creating AuthenticationDataHttp instance [#15221](https://github.com/apache/pulsar/pull/15221) +- Fix MessageDeduplication#inactiveProducers may not be persistence correctly [#15206](https://github.com/apache/pulsar/pull/15206) +- Cancel fencedTopicMonitoringTask when topic closed normally [#15202](https://github.com/apache/pulsar/pull/15202) +- Fix npe when doCacheEviction [#15184](https://github.com/apache/pulsar/pull/15184) +- Make health check fail if dead locked threads are detected [#15155](https://github.com/apache/pulsar/pull/15155) +- Fix parameter saslJaasBrokerSectionName in broker.conf [#15110](https://github.com/apache/pulsar/pull/15110) +- Fix potential to add duplicated consumer [#15051](https://github.com/apache/pulsar/pull/15051) +- Fix rewind failed when redeliverUnacknowledgedMessages [#15046](https://github.com/apache/pulsar/pull/15046) +- Fix race condition in updating lastMarkDeleteEntry field [#15031](https://github.com/apache/pulsar/pull/15031) +- Avoid heartbeat topic to offload [#15008](https://github.com/apache/pulsar/pull/15008) +- Evicting cache data by the slowest markDeletedPosition [#14985](https://github.com/apache/pulsar/pull/14985) +- Return if reset in progress [#14978](https://github.com/apache/pulsar/pull/14978) +- Dynamic update broker-level subscribe-rate limter [#14890](https://github.com/apache/pulsar/pull/14890) +- Fix wrong state for non-durable cursor [#14869](https://github.com/apache/pulsar/pull/14869) +- Support advertised listeners for HTTP and HTTPS services [#14839](https://github.com/apache/pulsar/pull/14839) +- Support dynamic update between non-zero values of topicPublisherThrottlingTickTimeMillis [#14782](https://github.com/apache/pulsar/pull/14782) +- Support dynamic update between non-zero values of brokerPublisherThrottlingTickTimeMillis [#14759](https://github.com/apache/pulsar/pull/14759) +- Fix incorrect entryId in warn log when reading entry from tiered storage [#14685](https://github.com/apache/pulsar/pull/14685) +- Optimize PositionImpl toString, compareTo and hashCode methods [#14678](https://github.com/apache/pulsar/pull/14678) +- Improve readability of ManagedCursorImpl source code [#14617](https://github.com/apache/pulsar/pull/14617) +- Intercept ACK command by BrokerInterceptor [#14616](https://github.com/apache/pulsar/pull/14616) +- Add filteredMsgCount for pulsar-admin broker-stats topics [#14531](https://github.com/apache/pulsar/pull/14531) +- Fix NPE when subscription is already removed [#14363](https://github.com/apache/pulsar/pull/14363) +- Fix backpressure handling in Jetty web server configuration [#14353](https://github.com/apache/pulsar/pull/14353) +- Optimize find nics process [#14340](https://github.com/apache/pulsar/pull/14340) +- Support pass http auth status [#14044](https://github.com/apache/pulsar/pull/14044) +- Support caching to drain backlog consumers [#12258](https://github.com/apache/pulsar/pull/12258) +- Strict bookie affinity group strategy [#12025](https://github.com/apache/pulsar/pull/12025) + +### Clients +- [PIP 74] Pulsar client memory limits + - Support auto scaled consumer receiver queue [#14494](https://github.com/apache/pulsar/pull/14494) + - Support dynamic limit of consumer receiver queue [#14400](https://github.com/apache/pulsar/pull/14400) + - Support consumer client memory limit [#15216](https://github.com/apache/pulsar/pull/15216) +- [Java] LastBatchSendNanoTime initialization [#17058](https://github.com/apache/pulsar/pull/17058) +- [Java] Fixed cnx channel Inactive causing the request fail to time out and fail to return [#17051](https://github.com/apache/pulsar/pull/17051) +- [Java] Release semaphore before discarding messages in batchMessageContainer [#17019](https://github.com/apache/pulsar/pull/17019) +- [Java] Reduce code duplication in admin client [#16377](https://github.com/apache/pulsar/pull/16377) +- [Java] Remove redundant check for chunked message TotalChunkMsgSize in ConsumerImpl [#16797](https://github.com/apache/pulsar/pull/16797) +- [Java] Fix client memory limit currentUsage leak and semaphore release duplicated in ProducerImpl [#16837](https://github.com/apache/pulsar/pull/16837) +- [Java] Forget to update memory usage when invalid message [#16835](https://github.com/apache/pulsar/pull/16835) +- [Java] Fix subscription topic name error [#16719](https://github.com/apache/pulsar/pull/16719) +- [Java] Send CloseConsumer on client timeout [#16616](https://github.com/apache/pulsar/pull/16616) +- [Java] Add message key if exists to deadLetter messages [#16615](https://github.com/apache/pulsar/pull/16615) +- [Java] Make DeadLetterPolicy deserializable [#16513](https://github.com/apache/pulsar/pull/16513) +- [Java] Improve performance of multi-topic consumer with more than one IO thread [#16336](https://github.com/apache/pulsar/pull/16336) +- [Java] Add initialization for the OpSendMsg [#16256](https://github.com/apache/pulsar/pull/16256) +- [Java] Replace ScheduledExecutor to improve performance of message consumption [#16236](https://github.com/apache/pulsar/pull/16236) +- [Java] Fix large message sometimes cannot be split into chunks [#16196](https://github.com/apache/pulsar/pull/16196) +- [Java] Only trigger the batch receive timeout when having pending batch receives requests [#16160](https://github.com/apache/pulsar/pull/16160) +- [Java] Fix the startMessageId can't be respected as the ChunkMessageID [#16154](https://github.com/apache/pulsar/pull/16154) +- [Java] Fix auto cluster failover can't resolve host bug [#16152](https://github.com/apache/pulsar/pull/16152) +- [Java] Switch to rely on Netty for Hostname Verification [#15824](https://github.com/apache/pulsar/pull/15824) +- [Java] Prevent the trigger running concurrently in the memory limit controller [#15737](https://github.com/apache/pulsar/pull/15737) +- [Java] Fix messages sent by producers without schema cannot be decoded [#15622](https://github.com/apache/pulsar/pull/15622) +- [Java] Remove sensitive msg from consumer/producer stats log [#15483](https://github.com/apache/pulsar/pull/15483) +- [Java] Add pending messages information while print the producer stats [#15440](https://github.com/apache/pulsar/pull/15440) +- [Java] Fix flaky BatchMessageTest by initializing lastBatchSendNanoTime [#15406](https://github.com/apache/pulsar/pull/15406) +- [Java] Check consumer schema null in advance [#15327](https://github.com/apache/pulsar/pull/15327) +- [Java] Fix inconsistent parameter of TopicPolicies.getSubscriptionDispatchRate [#15293](https://github.com/apache/pulsar/pull/15293) +- [Java] Fix typo in ConsumerBuilder [#15194](https://github.com/apache/pulsar/pull/15194) +- [Java] Fix performance regression with message listener [#15162](https://github.com/apache/pulsar/pull/15162) +- [Java] ConsumerBuilderImpl can not set null to deadLetterPolicy [#14980](https://github.com/apache/pulsar/pull/14980) +- [Java] Fix message publishing stuck when enabling batch [#14870](https://github.com/apache/pulsar/pull/14870) +- [Java] Returns immutable data set when use TableView [#14833](https://github.com/apache/pulsar/pull/14833) +- [Java] Avoid timer task run before previous subscribe complete [#14818](https://github.com/apache/pulsar/pull/14818) +- [Java] Support Reader Interceptor [#14729](https://github.com/apache/pulsar/pull/14729) +- [Java] Optimize pause when creating sub consumers in multi-topic consumer [#14566](https://github.com/apache/pulsar/pull/14566) +- [C++] Fix rpm and deb packaging [#17064](https://github.com/apache/pulsar/pull/17064) +- [C++] Add producerId to the log of closed producer [#17079](https://github.com/apache/pulsar/pull/17079) +- [C++] Add basic authentication [#15822](https://github.com/apache/pulsar/pull/15822) +- [C++] Add getLastMessageIdAsync in Consumer [#16182](https://github.com/apache/pulsar/pull/16182) +- [C++] Rename function name: pulsar_producer_configuration_set_crypto_failure_action [#16031](https://github.com/apache/pulsar/pull/16031) +- [C++] Generate correct well-known OpenID configuration URL [#15928](https://github.com/apache/pulsar/pull/15928) +- [C++] Unblock all threads when Pulsar client is closed [#15726](https://github.com/apache/pulsar/pull/15726) +- [C++] Avoid race condition causing double callback on close [#15508](https://github.com/apache/pulsar/pull/15508) +- [C++] Wait until event loop terminates when closing the Client [#15316](https://github.com/apache/pulsar/pull/15316) +- [C++] Remove the flaky and meaningless tests [#15271](https://github.com/apache/pulsar/pull/15271) +- [C++] Fix UnknownError might be returned for a partitioned producer [#15161](https://github.com/apache/pulsar/pull/15161) +- [C++] Fix single message metadata not set correctly [#15072](https://github.com/apache/pulsar/pull/15072) +- [C++] Add subscription properties to consumer for cpp [#15020](https://github.com/apache/pulsar/pull/15020) +- [C++] Fix connection is not closed when broker closes the connection to proxy[#14070](https://github.com/apache/pulsar/pull/14070) +- [C++] Fix send callback might not be invoked in key based batching [#14898](https://github.com/apache/pulsar/pull/14898) +- [C++] Fix C++ client compile error because of keyword optional is redundant in PaddingDemo.proto [#14862](https://github.com/apache/pulsar/pull/14862) +- [C++] Fix segmentation fault when creating socket failed [#14834](https://github.com/apache/pulsar/pull/14834) +- [C++] Fix the race condition of connect timeout task [#14823](https://github.com/apache/pulsar/pull/14823) +- [C++] Fix producer is never destructed until client is closed [#14797](https://github.com/apache/pulsar/pull/14797) +- [C++] Close messages_ when PartitionedConsumer is closed [#16887](https://github.com/apache/pulsar/pull/16887) +- [Python] Add getLastMessageIdAsync C binding [#16255](https://github.com/apache/pulsar/pull/16255) +- [Python] Fixed reserved keys is not removed when JsonSchema being encoded [#15947](https://github.com/apache/pulsar/pull/15947) +- [Python] Use MacOS 10.15 as the target OS version for Python wheel files [#15788](https://github.com/apache/pulsar/pull/15788) +- [Python] Removed dependencies only need by Python2 [#15460](https://github.com/apache/pulsar/pull/15460) +- [Python] Removed scripts to create wheel files in vagrant VMs [#15459](https://github.com/apache/pulsar/pull/15459) +- [Python] Adjusted script to build wheel for Python 3.7 on Mac [#15407](https://github.com/apache/pulsar/pull/15407) +- [Python] Change python cp35-cp35m lib build version to manylinux1 [#15180](https://github.com/apache/pulsar/pull/15180) +- [Python] Generate universal2 wheel files for MacOS [#15054](https://github.com/apache/pulsar/pull/15054) Review Comment: ```suggestion - [Python] Generate universal2 wheel files for macOS [#15054](https://github.com/apache/pulsar/pull/15054) ``` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: dev-unsubscr...@pulsar.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
