You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@pulsar.apache.org by Huanli Meng <hu...@streamnative.io> on 2021/06/03 16:01:00 UTC

[Pulsar Community Weekly Update] 2021-05-24 ~ 2021-05-30

Dear Pulsar enthusiast,

This is the Pulsar community weekly update for 2021-05-24 ~ 2021-05-30,
with updates on Pulsar client, broker, and so on.

This Pulsar community weekly update is also available at
https://streamnative.io/weekly/2021/2021-05/2021-05-31-pulsar-weekly.

All Pulsar community weekly updates are available at
https://streamnative.io/weekly/.
=======================================
*Development*

- Refactor the try-lock code pattern.

    https://github.com/apache/pulsar/pull/10742 ([@fantapsody](
https://github.com/fantapsody))

- [C++] Reduce the redundant `redeliverMessages` when the message listener
is enabled.

    https://github.com/apache/pulsar/pull/10726 ([@saosir](
https://github.com/saosir))

- [Transaction] Add the transaction Admin API `getPendingAckInternalStats`.

    https://github.com/apache/pulsar/pull/10725 ([@congbobo184](
https://github.com/congbobo184))

- [Schema] Support using `AutoProduceBytesSchema` as the function output
schema.

    https://github.com/apache/pulsar/pull/10716 ([@gaoran10](
https://github.com/gaoran10))

- [Common] Fix the inconsistent behavior in `LongPairRangeSet`.

    https://github.com/apache/pulsar/pull/10713 ([@315157973](
https://github.com/315157973))

- [C++] Add the C++ single file logger factory.

    https://github.com/apache/pulsar/pull/10712 ([@BewareMyPower](
https://github.com/BewareMyPower))

- [Transaction] Fix the `WriteFail` state of the ManagedLedger in the
transaction log.

    https://github.com/apache/pulsar/pull/10711 ([@congbobo184](
https://github.com/congbobo184))

- [Java Client] On multi-topic consumers, do not keep checking the
partitioned metadata.

    https://github.com/apache/pulsar/pull/10708 ([@merlimat](
https://github.com/merlimat))

- [Transaction] Add the transaction Admin APIs `getSlowTransactions` and
`getSlowTransactionsByCoordinatorId`.

    https://github.com/apache/pulsar/pull/10701 ([@congbobo184](
https://github.com/congbobo184))

- [Schema] In `AutoConsumeSchema.decode`, proxy the call to
`decode(payload, schemaversion)` correctly to the wrapped Schema.

    https://github.com/apache/pulsar/pull/10700 ([@eolivelli](
https://github.com/eolivelli))

- [Broker] Avoid making copies of internal maps when iterating the custom
HASH map.

    https://github.com/apache/pulsar/pull/10691 ([@merlimat](
https://github.com/merlimat))

- [Transaction] Add the transaction Admin API `getTransactionMetadata`.

    https://github.com/apache/pulsar/pull/10690 ([@congbobo184](
https://github.com/congbobo184))

- [Pulsar Proxy] Adjust the location of `logger.debug`.

    https://github.com/apache/pulsar/pull/10684 ([@mantuliu](
https://github.com/mantuliu))

- [Broker] Optimize `getTopicPolicies` to avoid throwing  an unnecessary
exception.

    https://github.com/apache/pulsar/pull/10683 ([@michaeljmarshall](
https://github.com/michaeljmarshall))

- [Transaction] Add the transaction Admin API `getCoordinatorInternalStats`.

    https://github.com/apache/pulsar/pull/10653 ([@congbobo184](
https://github.com/congbobo184))

- [Transaction] Add the transaction Admin APIs `getTransactionBufferStatus`
and `getPendingAckStatus`.

    https://github.com/apache/pulsar/pull/10650 ([@congbobo184](
https://github.com/congbobo184))

- [Transaction] Add the transaction Admin API
`getTransactionInPendingAckStats`.

    https://github.com/apache/pulsar/pull/10648 ([@congbobo184](
https://github.com/congbobo184))

- [Transaction] Add the transaction Admin API `getTransactionInBufferStats`.

    https://github.com/apache/pulsar/pull/10642 ([@congbobo184](
https://github.com/congbobo184))

- [Function] Add `--batch-source-config` switch to the Pulsar Admin source
API.

    https://github.com/apache/pulsar/pull/10593 ([@david-streamlio](
https://github.com/david-streamlio))

- [Broker] Migrate `NamespaceService` to use `MetadataStore`.

    https://github.com/apache/pulsar/pull/10532 ([@merlimat](
https://github.com/merlimat))

=======================================
*Notable Bug Fix*

- [Function] Use the default Kubernetes secret mount permission to allow
non-root users to read the authentication token.

    https://github.com/apache/pulsar/pull/10743 ([@zzzming](
https://github.com/zzzming))

- [ManagedLedger] Fix the original solution which is used to prevent race
conditions between timeout and completion.

    https://github.com/apache/pulsar/pull/10740 ([@lhotari](
https://github.com/lhotari))

- [ManagedLedger] Fix the scheduled task cancellation operation to make it
happen earlier in the `asyncClose` method.

    https://github.com/apache/pulsar/pull/10739 ([@lhotari](
https://github.com/lhotari))

- [Java Client] Add error message to
`setMaxPendingMessagesAcrossPartitions`.

    https://github.com/apache/pulsar/pull/10709 ([@wenbingshen](
https://github.com/wenbingshen))

- [Broker] Asynchronize the method `onManagedLedgerLastLedgerInitialize`
for `ManagedLedgerInterceptor`.

    https://github.com/apache/pulsar/pull/10706 ([@codelipenghui](
https://github.com/codelipenghui))

- [Broker] Fix the NPE that occurs when filtering read entries.

    https://github.com/apache/pulsar/pull/10704 ([@315157973](
https://github.com/315157973))

- [Broker] Fix the issue that `StackOverflowError` occurs when trying to
redeliver a large number of acknowledged messages.

    https://github.com/apache/pulsar/pull/10696 ([@massakam](
https://github.com/massakam))

- [Transaction] Fix the issue that the transaction acknowledges one topic
with multiple subscriptions.

    https://github.com/apache/pulsar/pull/10689 ([@congbobo184](
https://github.com/congbobo184))

- Fix binary license check issues and update Jersey to 2.34 for Pulsar SQL.

    https://github.com/apache/pulsar/pull/10682 ([@codelipenghui](
https://github.com/codelipenghui))

- [Broker] Fix issues in `advanceNonDurableCursors`.

    https://github.com/apache/pulsar/pull/10667 ([@jerrypeng](
https://github.com/jerrypeng))

- [Broker] Catch the exception in `checkSubscriptionTypesEnable`.

    https://github.com/apache/pulsar/pull/10341 ([@hangc0276](
https://github.com/hangc0276))

=======================================
*Event / News*

- Pulsar Virtual Summit North America 2021

    - Sign-up: https://hopin.com/events/pulsar-summit-north-america-2021

- [TGIP] Weekly live stream about Pulsar and its ecosystem.

  - All video recordings are available at [here](
https://streamnative.io/resource#tgip).

- [Intro to Apache Pulsar 101] Monthly live stream about Pulsar, including
concepts, architecture, and design.

  - Intro to Apache Pulsar EP04

    - 05/27: https://www.youtube.com/watch?v=6qpx37dRBB0

=======================================
*Blog / Article*

- Fast JMS for Apache Pulsar: Modernize and Reduce Costs with Blazing
Performance -- Enrico Olivelli

    -
https://www.datastax.com/blog/fast-jms-apache-pulsar?utm_source=thenewstack&utm_medium=twitter&utm_campaign=platform

- Monitoring the Health of Apache Pulsar with Pulsar Heartbeat -- Ming Luo

    -
https://www.datastax.com/blog/monitoring-health-apache-pulsar-pulsar-heartbeat

*If we miss anything, welcome to reply to this thread, thank you.*


*Cheers,Ran Gao, Huanli Meng*