Insights: apache/pulsar

50 Pull requests merged by 19 people

• [ML] Fix race condition in getManagedLedgerInternalStats when includeLedgerMetadata=true

  #15918 merged Jun 4, 2022

• [fix][doc] Code highlight not working on some pages

  #15919 merged Jun 3, 2022

• [Client] Continue shutdown of client when closing producers and consumers timeout

  #15921 merged Jun 3, 2022

• [CPP tests] Wait for mockZTS to start before connecting to it

  #15924 merged Jun 3, 2022

• [Broker] Close transactionBufferClient before closing the internal Pulsar client

  #15922 merged Jun 3, 2022

• [docs] Update pulsar-client-cpp/README.md instructions to cover python3

  #15923 merged Jun 3, 2022

• PIP-105 add support for updating the Subscription properties

  #15751 merged Jun 3, 2022

• [improve][kinesis-sink] Add unit test for Kinesis sink JsonConverter

  #15848 merged Jun 3, 2022

• [fix][ci] Fix tests memory leak due to mockito-inline

  #15513 merged Jun 3, 2022

• Issue 15750: PIP-105: Store Subscription properties

  #15757 merged Jun 3, 2022

• [Tests] Dump function logs when testJavaLoggingFunction test fails

  #15910 merged Jun 3, 2022

• [fix][owasp] Suppress CVE-2016-1000027 detection in Spring dependencies

  #15864 merged Jun 3, 2022

• [improve][broker]tidy update subscriptions dispatcher rate-limiter

  #15789 merged Jun 3, 2022

• [feature][doc] Add docs for the new S3 offloader

  #15835 merged Jun 3, 2022

• [Tests] Fix OutOfMemoryError and NoClassDefFoundErrors in tests

  #15911 merged Jun 3, 2022

• [CI] Collect heap dumps when OutOfMemoryError happens in unit tests

  #15909 merged Jun 2, 2022

• Avoid contended synchronized block on topic load

  #15883 merged Jun 2, 2022

• [Cli tools] Disable Pulsar client memory limit by default

  #15748 merged Jun 2, 2022

• [fix][io-use][docs] Removed extra 'f'

  #15888 merged Jun 2, 2022

• [improve][connector] Sink support custom acknowledge type

  #15491 merged Jun 2, 2022

• Fix malformed page for kafka-sink

  #15784 merged Jun 2, 2022

• [feature][client] Add cli cmd for subscription level dispatch-rate-limiter

  #15862 merged Jun 2, 2022

• [improve][broker] Make some methods in SchemasResourceBase async.

  #15821 merged Jun 2, 2022

• [improve][broker] Make some operation replication clusters methods in…

  #15760 merged Jun 2, 2022

• [feature][website] remove website build workflow due to it had been migrated to repo pulsar-site

  #15645 merged Jun 2, 2022

• [improve][connector] JDBC sinks: support Avro specific datatypes

  #15845 merged Jun 1, 2022

• [improve][broker] Make some methods of `ClusterBase` pure async.

  #15847 merged Jun 1, 2022

• [fix][dependency] Add OWASP suppression for openstack-keystone-2.5.0 and openstack-swift-2.5.0

  #15829 merged Jun 1, 2022

• [feature][sql] Add Pulsar Auth support for the Pulsar SQL

  #15571 merged Jun 1, 2022

• [fix][client] Fix conversion of `TimestampMillisConversion` has no effect when Jsr310Conversion enabled

  #15863 merged Jun 1, 2022

• Configure DLog Bookie, Pulsar, and Admin clients via pass through config

  #15818 merged Jun 1, 2022

• [feature][website]update preview scripts

  #15873 merged Jun 1, 2022

• Switch to rely on Netty for Hostname Verification

  #15824 merged Jun 1, 2022

• [Tests] Fix resource leaks in Pulsar IO integration tests

  #15866 merged Jun 1, 2022

• [feature][website] api generate script

  #15872 merged Jun 1, 2022

• [fix][broker] Fix NPE in MessageDeduplication.

  #15820 merged Jun 1, 2022

• [Tests] Fix flaky test ConnectionTimeoutTest

  #15865 merged May 31, 2022

• [Tests] Fix flaky MultiTopicsConsumerImplTest

  #15851 merged May 31, 2022

• [fix][kinesis-sink] Handle Avro collections native types (GenericData.Array and Utf8 map keys)

  #15432 merged May 31, 2022

• Bump spring version to 5.3.20 to solve CVE-2022-22970

  #15699 merged May 31, 2022

• [fix][admin] Fix check on create function class name

  #15700 merged May 31, 2022

• [Broker] Add timeout to closing CoordinationServiceImpl

  #15777 merged May 31, 2022

• [fix][python]Fix generated Python protobuf code not compatible with latest protobuf package

  #15846 merged May 31, 2022

• [feature][doc] Sync language tab choices

  #15812 merged May 31, 2022

• [improve][doc] Add support for chained authentication providers with the same auth method name

  #15799 merged May 31, 2022

• [fix][function] Fix UserConfigFunction example

  #15240 merged May 30, 2022

• [improve][connector] JDBC Sinks: support KeyValue schema

  #15807 merged May 30, 2022

• [fix][doc] Remove the domain name of Pulsar website from doc links

  #15816 merged May 30, 2022

• [fix][doc] fixed bad link in Pulsar CLI Tools

  #15808 merged May 30, 2022

• [branch-2.9] Add publishRateLimitedTimes to topic metrics.

  #15739 merged May 29, 2022

38 Pull requests opened by 28 people

• [fix][broker]Fix topic-level replicator rate limiter not init

  #15825 opened May 29, 2022

• Match exception if connection just connected #15764

  #15826 opened May 29, 2022

• [fix][python-function] Fix the failed CPP test CI caused by python function

  #15827 opened May 30, 2022

• doc: en to zh-cn

  #15833 opened May 30, 2022

• [WIP] [Snip 145] introduce two phase deletion protocol.

  #15834 opened May 30, 2022

• [Fix][broker] Fix NPE when ledger id not found in `OpReadEntry`

  #15837 opened May 30, 2022

• [improve][website] Suggest pulsar-admin-client for Node

  #15839 opened May 30, 2022

• [fix][txn] Transaction metadata client cnx is null

  #15840 opened May 30, 2022

• [improve][doc] numFunctionPackageReplicas explanation

  #15842 opened May 30, 2022

• [improve][broker] Make delete topic async

  #15843 opened May 30, 2022

• [fix][client] `ZeroQueueConsumer` may not increase the permit after unloading the topic.

  #15852 opened May 31, 2022

• fix: make internalSetMaxConsumersPerSubscription async

  #15857 opened May 31, 2022

• Support Tiered-Storage Provider for Tencent Cloud COS

  #15860 opened May 31, 2022

• add metric for InMemoryDelayedDeliveryTracker's memory usage

  #15867 opened May 31, 2022

• Allow pulsar_tool_env.sh PULSAR_MEM to be Overridden

  #15868 opened May 31, 2022

• [fix][broker] remove topic -> namespace cache of LedgerOffloaderStatsImpl

  #15869 opened Jun 1, 2022

• [fix][broker][monitoring] provide namespace level metrics for SchemaRegistry.

  #15870 opened Jun 1, 2022

• [fix][txn]Fix transasction ack batch message

  #15875 opened Jun 1, 2022

• [improve][rest] Refactor Rest produce part

  #15876 opened Jun 1, 2022

• [fix][clients]Check pendingIndividualBatchIndexAcks size in doIndividualBatchAckAsync

  #15877 opened Jun 1, 2022

• [fix][doc] Fixed binary protocol naming and descriptions

  #15878 opened Jun 1, 2022

• [improve][broker] Make some operation subscription dispatchRate methods in Namespaces async

  #15880 opened Jun 1, 2022

• [fix][doc] Add saslJaasServerRoleTokenSignerSecret parameter in security-kerberos.md

  #15884 opened Jun 2, 2022

• [improve][broker] make split namespaces bundle async

  #15886 opened Jun 2, 2022

• [fix][doc] Add context for schemaRegistryCompatibilityCheckers

  #15887 opened Jun 2, 2022

• [improve][broker] make get topic hash positions async

  #15889 opened Jun 2, 2022

• [improve][doc] Highlight important tips

  #15890 opened Jun 2, 2022

• [tiered-storage] add s3 compatible storage provider for the offloader

  #15893 opened Jun 2, 2022

• Support local batch memory metadata store.

  #15901 opened Jun 2, 2022

• [feature][functions]Create a built-in Function implementing the most common basic transformations

  #15903 opened Jun 2, 2022

• [feature][functions][WIP]Support auth for function go

  #15907 opened Jun 2, 2022

• Enable TCP/IP keepalive for all ZK client connections in all components started with bin/pulsar

  #15908 opened Jun 2, 2022

• [Fix][Tiered Storage] Eagerly Delete Offloaded Segments On Topic Deletion

  #15914 opened Jun 2, 2022

• [fix][client] Register logical type conversions when use `SchemaDefinition.<T>builder().withJsonDef()`

  #15915 opened Jun 3, 2022

• [improve][broker] Make `NamespaceBase#deleteNamespace` to pure async

  #15917 opened Jun 3, 2022

• [CI] Run pulsar-io/elastic-search tests in separate build job

  #15926 opened Jun 3, 2022

• [fix][auth] Generate correct well-known OpenID configuration URL

  #15928 opened Jun 4, 2022

• [fix] [admin] Enhanced verification for retention policy

  #15929 opened Jun 4, 2022

23 Issues closed by 13 people

• Flaky-test: AdminApiTransactionTest.testGetPendingAckInternalStats

  #15916 closed Jun 4, 2022

• [Doc] code highlighting issues

  #15854 closed Jun 3, 2022

• Flaky-test: PartitionedSystemTopicTest.cleanup

  #15920 closed Jun 3, 2022

• (Flaky-test) AuthPluginTest.testAthenz failure

  #6298 closed Jun 3, 2022

• Topic internalStats/stats get failed: Topic not found

  #15871 closed Jun 3, 2022

• PIP-105 Per-subscription properties are not persistent to MetadataStore

  #15750 closed Jun 3, 2022

• Update Pulsar to version 2.10.0,bin/pulsar-admin command invalid.

  #15152 closed Jun 3, 2022

• Flaky-test: ClientCnxTest.testClientCnxTimeout

  #15897 closed Jun 3, 2022

• Flaky-test: MessageImplTest.testMessageBrokerAndEntryMetadataTimestampMissed

  #15689 closed Jun 3, 2022

• Flaky-test: BinaryProtoLookupServiceTest.maxLookupRedirectsTest1

  #15793 closed Jun 3, 2022

• Flaky-test: ConnectionTimeoutTest.testLowTimeout

  #15764 closed Jun 2, 2022

• [Doc] Kafka Sink documentation is malformed

  #15783 closed Jun 2, 2022

• SchemaDefinitionBuilder.withJSR310ConversionEnabled(true) has no effect (it should use timestamp-millis for java.time.Instant)

  #15858 closed Jun 1, 2022

• Pulsar IO tests leak resources in Kafka related tests

  #15853 closed Jun 1, 2022

• [Website] layout of "powered by" page is incorrect

  #15831 closed Jun 1, 2022

• Flaky-test: MultiTopicsConsumerImplTest.testParallelSubscribeAsync

  #15850 closed May 31, 2022

• CoordinationServiceImpl.close hangs and doesn't complete

  #15774 closed May 31, 2022

• [Bug] Producer timeout when sending message with huge properties.

  #13560 closed May 31, 2022

• [website] Improve the user experience in switch tab

  #10282 closed May 31, 2022

• [Doc] Add doc for chained authentication

  #15055 closed May 31, 2022

• test

  #15828 closed May 30, 2022

• PROBLEM: messages come as encoded

  #12274 closed May 29, 2022

• Ensure the deletion consistency of topic and schema

  #12795 closed May 29, 2022

31 Issues opened by 22 people

• [Doc] Get Started in Kubernetes Step 4 - Use Pulsar Manager to manage the cluster is incorrect

  #15927 opened Jun 3, 2022

• downloads page link in documentation is not correct

  #15925 opened Jun 3, 2022

• Flaky-test: GeoReplicationTest.testTopicReplication

  #15913 opened Jun 2, 2022

• [Cli tools] Add command line option for configuring the memory limit

  #15912 opened Jun 2, 2022

• [Doc] website about pulsar java client

  #15906 opened Jun 2, 2022

• [Doc] Threshold Shedder documentation - need to add documentation on the individual weights

  #15905 opened Jun 2, 2022

• [Doc] Load Balancer - Broker overload thresholds does not apply to some Shedding algorithms

  #15904 opened Jun 2, 2022

• [PIP] PIP-173 : Create a built-in Function implementing the most common basic transformations

  #15902 opened Jun 2, 2022

• Support batch local memory metadata store.

  #15900 opened Jun 2, 2022

• SchemaDefinition.<T>builder().withJsonDef() does not register logical type conversions (e.g. java.lang.Instant)

  #15899 opened Jun 2, 2022

• KeyShared consumers with sticky hash range generate backlog with messages not fall within consumer hash range - v2.9.2

  #15898 opened Jun 2, 2022

• Flaky-test: PulsarLedgerIdGeneratorTest.testGenerateLedgerId

  #15896 opened Jun 2, 2022

• Flaky-test: RackAwareTest.testRackUpdate

  #15895 opened Jun 2, 2022

• Flaky-test: PersistentTopicsTest.testTriggerCompactionTopic

  #15894 opened Jun 2, 2022

• [improve][doc] highlight important notice

  #15892 opened Jun 2, 2022

• "Topic policies cache have not init" randomly happen on different topics in the same namespace

  #15891 opened Jun 2, 2022

• [Discuss] Pulsar client : Connect Command add `keep_alive_interval`

  #15885 opened Jun 2, 2022

• Fatal error with pulsar client and Java 17(open jdk 17.0.2_8-7-1937)

  #15882 opened Jun 1, 2022

• Inactive topic cleaning up does not work properly

  #15881 opened Jun 1, 2022

• [Doc] broken link

  #15879 opened Jun 1, 2022

• metadata-store thread should not execute onPoliciesUpdate synchronized when PoliciesUpdate

  #15861 opened May 31, 2022

• PIP-172 : Introduce the `HEALTH_CHECK` command in the binary protocol

  #15859 opened May 31, 2022

• make internalSetMaxConsumersPerSubscription async

  #15856 opened May 31, 2022

• Schema evolution docs make reference to unexplained schemaRegistryCompatibilityCheckers flag

  #15855 opened May 31, 2022

• PIP-171: Expose SubscriptionProperties to the Consumer interface

  #15849 opened May 31, 2022

• Python Client doesn't clean up reserved field when publishing message with Schema

  #15844 opened May 30, 2022

• deleteTopic need to be async

  #15841 opened May 30, 2022

• Is it possible to migrate from zookeeper metadata store to etcd?

  #15838 opened May 30, 2022

• Message has no redelivery count if subscription type is Exclusive or Failover

  #15836 opened May 30, 2022

• [Bug] Get batch size return 1 when is not Individual ack mode

  #15832 opened May 30, 2022

• The standalone pulsar runs sql-worker error with macOS.

  #15830 opened May 30, 2022

254 Unresolved conversations

Sometimes conversations happen on old items that aren’t yet closed. Here is a list of all the Issues and Pull Requests with unresolved conversations.

• [improve][function] Get function class name from the NAR when using built-in functions

  #15693 commented on Jun 2, 2022 • 14 new comments

• [improve][doc][do-not-merge] single source of truth for functions CLI and add a table for yml configs

  #15389 commented on Jun 2, 2022 • 11 new comments

• [BUG] Producer with name xxx is already connect to topic

  #13342 commented on Jun 2, 2022 • 10 new comments

• [improve][proxy] Support zero-copy of NIC to NIC on Proxy

  #15678 commented on Jun 2, 2022 • 10 new comments

• [WIP] Track the progress of PIP-149-Making the REST Admin API fully async

  #15043 commented on Jun 2, 2022 • 9 new comments

• [admin][txn] Add transaction admin to get recover time in stats.

  #15654 commented on Jun 3, 2022 • 6 new comments

• [PIP-150][improve][broker] Support read the message of startMessageId position on the broker side

  #15568 commented on Jun 1, 2022 • 5 new comments

• [fix][client] Remove consumer when close consumer command is received

  #15761 commented on Jun 1, 2022 • 5 new comments

• I want pulsar-discovery to come back.

  #15225 commented on Jun 3, 2022 • 4 new comments

• [fix][broker] fix npe when doCacheEviction

  #15184 commented on Jun 1, 2022 • 4 new comments

• [fix][schema] Fix update schema forward compatibility strategy behavior

  #15718 commented on Jun 2, 2022 • 4 new comments

• [improve][txn] Support ack message list for transaction

  #15729 commented on Jun 3, 2022 • 4 new comments

• [Client] Donate Haskell client to Pulsar

  #9076 commented on May 31, 2022 • 3 new comments

• [Discussion] New Pulsar Website

  #15538 commented on Jun 2, 2022 • 3 new comments

• Standalone broker on MacOS often fail to start after workstation sleep or reboot

  #15401 commented on Jun 2, 2022 • 3 new comments

• [PIP-165] Auto release client useless connections

  #15516 commented on Jun 3, 2022 • 3 new comments

• [fix] [client-consumer] NotifyPendingReceivedCallback when zeroConsumerImpl received batch message firstly , then close consumer.

  #15144 commented on Jun 1, 2022 • 3 new comments

• [Broker][Proxy][Function worker] Remove duplicate servlet filter instances to fix backpressure

  #15637 commented on Jun 4, 2022 • 3 new comments

• [Improve][txn] extend admin tools for transaction component.

  #15675 commented on Jun 3, 2022 • 3 new comments

• [improve][txn] Add a admin tool to check message pending ack stats

  #15682 commented on Jun 3, 2022 • 3 new comments

• [fix][Admin CLI docs][Do-not-merge] Sync the description and default value of `--processing-guarantees`

  #15775 commented on Jun 2, 2022 • 3 new comments

• [fix][test] Fix schema not found check on unit test

  #15815 commented on Jun 1, 2022 • 3 new comments

• [Transactions] NullPointerException during Java Client bootstrap

  #15375 commented on May 30, 2022 • 2 new comments

• Too many schema ledgers for transaction_buffer_snapshot topic

  #14874 commented on May 30, 2022 • 2 new comments

• Can we provide support for mdc

  #14493 commented on May 30, 2022 • 2 new comments

• PIP 129: Introduce intermediate state for ledger deletion

  #13526 commented on May 30, 2022 • 2 new comments

• `receiver_queue_size` of 1 does not work; Shared consumers with receiver_queue_size=1 can "steal" messages that other consumers should receive

  #15703 commented on May 30, 2022 • 2 new comments

• [Doc] [New Website]

  #15813 commented on May 30, 2022 • 2 new comments

• Topic is already fenced

  #15451 commented on May 31, 2022 • 2 new comments

• bookie failed to decommission successfully

  #15776 commented on Jun 1, 2022 • 2 new comments

• Flaky-test: PulsarFunctionsJavaThreadTest.testJavaLoggingFunction

  #15392 commented on Jun 2, 2022 • 2 new comments

• Flaky-test: ZKSessionTest.testSessionLost

  #14107 commented on Jun 2, 2022 • 2 new comments

• Unable to build kubernetes objects from release manifest: error validating "" error validating data: [ValidationError(Certificate.spec): unknown field "keyAlgorithm" in io.cert-manager.v1.Certificate.spec

  #14547 commented on Jun 4, 2022 • 2 new comments

• [PulsarAdmin] add get active brokers api without cluster name

  #14702 commented on May 30, 2022 • 2 new comments

• [improve][deploy] changed the default GC options to ZGC from G1GC

  #15762 commented on Jun 3, 2022 • 2 new comments

• Fix schema stats prometheus summary memory leak

  #15801 commented on Jun 3, 2022 • 2 new comments

• Flaky-test: PulsarSinksTest.testKinesis / KinesisSinkTester.addMoreRecordsAndGetMillisBehindLatest

  #15364 commented on May 29, 2022 • 1 new comment

• Python Pulsar Function Deployed on 2.9.1

  #14915 commented on May 29, 2022 • 1 new comment

• [Website] Stop re-generating client docs based on SNAPSHOT versions

  #14838 commented on May 29, 2022 • 1 new comment

• [Java Pulsar Client] Unable to use proxyServiceUrl - SNI routing

  #14544 commented on May 29, 2022 • 1 new comment

• [bug](Replicated subscription): slow rate consumer makes replicated subscription works unexpected.

  #13823 commented on May 29, 2022 • 1 new comment

• Ability to store metadata about functions

  #13807 commented on May 29, 2022 • 1 new comment

• Multiple instance of producers sharing the same producer name

  #13806 commented on May 29, 2022 • 1 new comment

• Unable to load the library 'org_apache_pulsar_shade_netty_transport_native_epoll_x86_64', trying other loading

  #13803 commented on May 29, 2022 • 1 new comment

• Why is there this annotation? org.apache.pulsar.client.impl.conf.ClientConfigurationData#@jsonIgnore

  #13779 commented on May 29, 2022 • 1 new comment

• Scale up the pod number of bookie or broker cant improve the performance of throughput and my hardware resource is still free enough

  #13774 commented on May 29, 2022 • 1 new comment

• Produce message using REST API through Proxy

  #13768 commented on May 29, 2022 • 1 new comment

• Pulsar 2.9 topic produced through REST not support Authorization

  #13766 commented on May 29, 2022 • 1 new comment

• JWT authentication and authorization not working on standalone cluster

  #13743 commented on May 29, 2022 • 1 new comment

• Replace -XX:+DisableExplicitGC with -XX:+ExplicitGCInvokesConcurrent

  #13737 commented on May 29, 2022 • 1 new comment

• cpp client coredump

  #13735 commented on May 29, 2022 • 1 new comment

• PIP-136: Sync Pulsar policies across multiple clouds

  #13728 commented on May 29, 2022 • 1 new comment

• The topic monitoring information is incorrect

  #13721 commented on May 29, 2022 • 1 new comment

• should we add a metrics to show the top storage in bookeeper

  #13718 commented on May 29, 2022 • 1 new comment

• [2.7.4] NPE while open reader to pulsar topic

  #13713 commented on May 29, 2022 • 1 new comment

• [2.8.2] error while create opSendMsg by batch message container - zstd overflow detected

  #13712 commented on May 29, 2022 • 1 new comment

• Netty - set EndpointIdentificationAlgorithm to get rid of CWE-295

  #13705 commented on May 29, 2022 • 1 new comment

• [Discuss] Byte schema compatibility issue

  #13701 commented on May 29, 2022 • 1 new comment

• [branch-2.9] Flaky-test: BatchSourceExecutorTest.testLifeCycle()

  #13696 commented on May 29, 2022 • 1 new comment

• Broker LedgerHandle internal metadata is inconsistent with latest ledger metadata in zk

  #13693 commented on May 29, 2022 • 1 new comment

• Rebalance function workers

  #13692 commented on May 29, 2022 • 1 new comment

• Compact topic need redeliver epoch implementation.

  #13690 commented on May 29, 2022 • 1 new comment

• Token Authentication by context - pulsar-function-go

  #13684 commented on May 29, 2022 • 1 new comment

• Get topics list Timeout

  #13664 commented on May 29, 2022 • 1 new comment

• Flaky-test: LockManagerTest.updateValue

  #13663 commented on May 29, 2022 • 1 new comment

• Spawned function worker pod does not have auth related params while downloading functions

  #13648 commented on May 29, 2022 • 1 new comment

• NamespaceIsolationPolicies may need support priority

  #13643 commented on May 29, 2022 • 1 new comment

• org.apache.bookkeeper.client.LedgerHandle - ReadException on ledgerId

  #13642 commented on May 29, 2022 • 1 new comment

• [PIP 133] Pulsar Functions Add API For Accessing Other Function States

  #13633 commented on May 29, 2022 • 1 new comment

• [Docs] Need to add suppressions instruction to readme for configuring IntelliJ checkstyle rules

  #13631 commented on May 29, 2022 • 1 new comment

• Flaky-test: ReplicatorSubscriptionTest.testGetReplicatedSubscriptionStatus

  #13626 commented on May 29, 2022 • 1 new comment

• Flaky-test: Spy creation sporadically fails in some tests and causes Mockito misuse warning

  #13620 commented on May 29, 2022 • 1 new comment

• [Doc] add explanations for topic retention policy and other commands

  #13617 commented on May 29, 2022 • 1 new comment

• Enable message offset auto commit in pulsar client consumer

  #13594 commented on May 29, 2022 • 1 new comment

• [Doc] add examples of "how to use metrics" to "Metrics" guide

  #13588 commented on May 29, 2022 • 1 new comment

• [Doc] add docs for "how to develop plugin" in "development" guide

  #13585 commented on May 29, 2022 • 1 new comment

• apachepulsar/pulsar-all:2.8.2 docker image missing

  #13576 commented on May 29, 2022 • 1 new comment

• websocket: Producers will fail the first time they send a message

  #13568 commented on May 29, 2022 • 1 new comment

• The Producer deliverAfter‘s time should use the broker's time

  #13567 commented on May 29, 2022 • 1 new comment

• Offload compacted ledger into tiered storage

  #13559 commented on May 29, 2022 • 1 new comment

• Producers and consumers throw PulsarClientException.AlreadyClosedException

  #13532 commented on May 29, 2022 • 1 new comment

• PIP 130: Apply redelivery backoff policy for ack timeout

  #13528 commented on May 29, 2022 • 1 new comment

• if you installed 'Win32/Win64 OpenSSL' on windows10,compiling Pulsar C++ client library will failure

  #13527 commented on May 29, 2022 • 1 new comment

• [pulsar-client] Support receiverQueueRefillThreshold configuration.

  #13524 commented on May 29, 2022 • 1 new comment

• kill the broker or ack takes a long time, which will cause the cluster traffic to drop instantaneously

  #13523 commented on May 29, 2022 • 1 new comment

• minio support

  #13493 commented on May 29, 2022 • 1 new comment

• PIP-137: Pulsar Client Shared State API

  #13490 commented on May 29, 2022 • 1 new comment

• Failed to create subscription

  #13489 commented on May 29, 2022 • 1 new comment

• [bug](zkclient): ledger znode delete incomplete when broker delete topic

  #13480 commented on May 29, 2022 • 1 new comment

• feat(offloader): support kerberos config set for hdfs offloader

  #13441 commented on May 29, 2022 • 1 new comment

• We can still get topic’s schema When deleting both the topic&schema

  #13431 commented on May 29, 2022 • 1 new comment

• [Pulsar SQL] Query data with empty schema version for no-bytes schema type

  #13427 commented on May 29, 2022 • 1 new comment

• python sdk bug "Pulsar error: IncompatibleSchema"

  #13419 commented on May 29, 2022 • 1 new comment

• [Doc] add docs for additionalJavaRuntimeArguments

  #13411 commented on May 29, 2022 • 1 new comment

• Add custom properties for the reconsumeLater interface

  #13410 commented on May 29, 2022 • 1 new comment

• Topic Policies get/set not working properly

  #13406 commented on May 29, 2022 • 1 new comment

• [Transaction] Add transaction coordinator disconnect command.

  #13405 commented on May 29, 2022 • 1 new comment

• Setting `PULSAR_EXTRA_OPTS` causes the process to run without significant default JVM options

  #13382 commented on May 29, 2022 • 1 new comment

• 【Critical issue】pulsar-broker block when process start

  #13362 commented on May 29, 2022 • 1 new comment

• Functions: NullPointerException in FunctionStatsManager.reset

  #13358 commented on May 29, 2022 • 1 new comment

• Support user defined and pluggable consumer selector

  #13347 commented on May 29, 2022 • 1 new comment

• Pulsar branch-2.9 build failure in auditwheel running build-wheel-file-within-docker.sh

  #13457 commented on May 29, 2022 • 1 new comment

• PulsarAdmin Java library: sometimes it fails with NullPointerException

  #15673 commented on May 29, 2022 • 1 new comment

• `receiver_queue_size` has no effect on partitioned topics, but is allowed

  #15702 commented on May 30, 2022 • 1 new comment

• Cursor recover took extreme long time

  #15390 commented on May 30, 2022 • 1 new comment

• [PIP-159]Reuse transaction buffer reader

  #15334 commented on May 30, 2022 • 1 new comment

• YAMLLoadWarning in bin/gen-yml-from-env.py script

  #14956 commented on May 30, 2022 • 1 new comment

• [Doc] Regression in pulsar CLI docs

  #14946 commented on May 30, 2022 • 1 new comment

• [CI] `Auto Labeling` failed

  #14942 commented on May 30, 2022 • 1 new comment

• Abount add TDengine Connector to Pulsar.

  #14931 commented on May 30, 2022 • 1 new comment

• Compaction stop on topic __transaction_buffer_snapshot

  #14882 commented on May 30, 2022 • 1 new comment

• Subscription replication did not take effect

  #14652 commented on May 30, 2022 • 1 new comment

• SIGSEGV error in docker (Java client)

  #14534 commented on May 30, 2022 • 1 new comment

• [Blog] 2.9.0 announcement blog

  #13338 commented on May 30, 2022 • 1 new comment

• Wheel for pulsar-client 2.8.1, Python 3.9 and OS X x86_64 is missing

  #13334 commented on May 30, 2022 • 1 new comment

• Migrate topic authorization data to topic policies

  #13330 commented on May 30, 2022 • 1 new comment

• Split FutureUtils in to dedicated mvn package?

  #13325 commented on May 30, 2022 • 1 new comment

• [function] `--update-auth-data` doesn't work

  #13307 commented on May 30, 2022 • 1 new comment

• File Connector repeats reading the same file if not deleted

  #13301 commented on May 30, 2022 • 1 new comment

• Flaky tests in branch-2.7

  #13299 commented on May 30, 2022 • 1 new comment

• Pulsar does not run after the first time - standalone mode

  #13294 commented on May 30, 2022 • 1 new comment

• c++ client Producer with name 'xxx-18-31667' is already connected to topic

  #13289 commented on May 30, 2022 • 1 new comment

• PIP 116: Create Pulsar Writing Style Guide

  #13288 commented on May 30, 2022 • 1 new comment

• Find the mapping topic according to the scope of the bundle

  #13275 commented on May 30, 2022 • 1 new comment

• PoolMessage and DLQ can not work together

  #13269 commented on May 30, 2022 • 1 new comment

• Increase the metric of topic current limit time

  #13255 commented on May 30, 2022 • 1 new comment

• [Enhancement] Use SonarQube to run static code analysis for detecting bugs early

  #13244 commented on May 30, 2022 • 1 new comment

• Should introduce deleting state for ledger deletion

  #13238 commented on May 30, 2022 • 1 new comment

• PIP 113: Update Pulsar Website Design & Content

  #13235 commented on May 30, 2022 • 1 new comment

• Deploy function worker in a separate kubernetes

  #13227 commented on May 30, 2022 • 1 new comment

• Broker Java heap space OOM

  #13224 commented on May 30, 2022 • 1 new comment

• PIP 112: Generate Release Notes Automatically

  #13207 commented on May 30, 2022 • 1 new comment

• [Pulsar-Reader] Support setting specified end MessageID or publish time.

  #13175 commented on May 30, 2022 • 1 new comment

• Pulsar admin api golang client

  #13174 commented on May 30, 2022 • 1 new comment

• Elasticsearch sink `keyIgnore` config support non-keyvalue schemas (i.e. avro and json)

  #13173 commented on May 30, 2022 • 1 new comment

• Flaky-test: PulsarStateTest.testPythonWordCountFunction

  #6197 commented on May 30, 2022 • 1 new comment

• Provide a more accurate message backlog value

  #7623 commented on May 30, 2022 • 1 new comment

• Endless Topic HTTP Request Redirects

  #13946 commented on May 30, 2022 • 1 new comment

• Terminating a partitioned topic that has just been created often fails with "PreconditionFailedException: Failed to find ownership for topic..."

  #15433 commented on May 30, 2022 • 1 new comment

• permission maybe wrong for RocksdbMetadataStore

  #15400 commented on May 31, 2022 • 1 new comment

• Attempting to delete persistent topics shortly after they are created yields intermittent "BKException$BKUnexpectedConditionException: Unexpected condition"

  #13172 commented on May 31, 2022 • 1 new comment

• [DISCUSS] proposal: APISIX support Pulsar service plugin

  #13158 commented on May 31, 2022 • 1 new comment

• Python pulsar-client not available for Apple Silicon (M1)

  #13153 commented on May 31, 2022 • 1 new comment

• Not able to run pulsar postgres jdbc sink

  #13151 commented on May 31, 2022 • 1 new comment

• Cluster switching failed for producers

  #13148 commented on May 31, 2022 • 1 new comment

• Add a watchdog monitor to monitor and log long-running metadata-store callback tasks

  #13129 commented on May 31, 2022 • 1 new comment

• Pulsar Function's cannot reference classes inside NAR file when running Pulsar in standalone mode

  #13128 commented on May 31, 2022 • 1 new comment

• sql EOF exception when empty payload message in topic

  #13127 commented on May 31, 2022 • 1 new comment

• [Build] Java compiling can fail with NullPointerException and mask a compilation issue

  #13126 commented on May 31, 2022 • 1 new comment

• Failed to deserialize load report data

  #13109 commented on May 31, 2022 • 1 new comment

• [Transactions] SystemTopicBaseTxnBufferSnapshotService.close could hang forever

  #13103 commented on May 31, 2022 • 1 new comment

• Pulsar support for Apache Avro library as published by Apache

  #13096 commented on May 31, 2022 • 1 new comment

• [Tests] LockManagerImpl.close hangs and causes the test run to timeout eventually

  #13092 commented on May 31, 2022 • 1 new comment

• Go client keep receive close from broker

  #13084 commented on May 31, 2022 • 1 new comment

• Pulsar Broker: Enable EC256 Support for WebService

  #13070 commented on May 31, 2022 • 1 new comment

• function worker doesn't use configurationStoreServers parameter while creating function

  #11261 commented on May 31, 2022 • 1 new comment

• Topic is temporarily unavailable

  #14941 commented on Jun 1, 2022 • 1 new comment

• Supporting RISC-V (OpenJ9)

  #13067 commented on Jun 1, 2022 • 1 new comment

• [BUG] Judgment criteria for reconnecting the producer

  #13061 commented on Jun 1, 2022 • 1 new comment

• ERROR Failed to evaluate client token: javax.security.sasl.SaslException: Final handshake step failed

  #13060 commented on Jun 1, 2022 • 1 new comment

• [Doc] add docs for configuring rack

  #13052 commented on Jun 1, 2022 • 1 new comment

• [Doc] add explanations for function (autoack and nack)

  #13051 commented on Jun 1, 2022 • 1 new comment

• Operation failed on schema upload to a topic while configuring a jdbc sink

  #13046 commented on Jun 1, 2022 • 1 new comment

• [Doc] add docs for Log4J2 appender

  #13036 commented on Jun 1, 2022 • 1 new comment

• Pulsar sink is not running ( sink status : false )

  #13021 commented on Jun 1, 2022 • 1 new comment

• Pulsar IO support Clickhouse Load Balance

  #12998 commented on Jun 1, 2022 • 1 new comment

• Unable to create a JDBC sink

  #12987 commented on Jun 1, 2022 • 1 new comment

• Following the getting started guide results in a ClassNotFound exception at runtime.

  #15791 commented on Jun 1, 2022 • 1 new comment

• NarUnpacker create directory and file without permission check.

  #15411 commented on Jun 2, 2022 • 1 new comment

• Pulsar Perf OutOfDirectMemoryError: failed to allocate 16777216 byte(s) of direct memory (used: 28621930496, max: 28631367680)

  #14983 commented on Jun 2, 2022 • 1 new comment

• es sink start error

  #14592 commented on Jun 2, 2022 • 1 new comment

• [PIP-149] Making the REST Admin API fully async

  #14365 commented on Jun 2, 2022 • 1 new comment

• [admin] enhance rest api to help calculate the ending MessageID with a starting MessageID and an offset number

  #13160 commented on Jun 2, 2022 • 1 new comment

• [PIP-168] Support zero-copy of NIC to NIC on Proxy

  #15631 commented on Jun 2, 2022 • 1 new comment

• Flaky-test: RackAwareTest.testPlacement

  #14106 commented on Jun 2, 2022 • 1 new comment

• PIP-157: Bucketing topic metadata to allow more topics per namespace

  #15254 commented on Jun 3, 2022 • 1 new comment

• [Doc] Pulsar-Admin docs miss some new features

  #14987 commented on Jun 3, 2022 • 1 new comment

• Too many TCP Connections are in CLOSE_WAIT status freeze broker v 2.7.4

  #14826 commented on Jun 3, 2022 • 1 new comment

• Not enough non-faulty bookies available

  #13167 commented on Jun 3, 2022 • 1 new comment

• Setting topic permission under load

  #2952 commented on Jun 3, 2022 • 1 new comment

• Flaky-test: PersistentDispatcherFailoverConsumerTest.testAddRemoveConsumer

  #14540 commented on Jun 3, 2022 • 1 new comment

• Flaky-test: SimpleProducerConsumerTestStreamingDispatcherTest.testRedeliveryFailOverConsumer

  #15422 commented on Jun 4, 2022 • 1 new comment

• Unable to run Pulsar Python client on M1 Mac, including when building from source on master

  #15417 commented on Jun 4, 2022 • 1 new comment

• C + + client batch consumption submission offset

  #14926 commented on Jun 4, 2022 • 1 new comment

• Fix unable to subscribe non-persistent topics via regex.

  #12990 commented on Jun 1, 2022 • 1 new comment

• [Issue 12998][io] enhance clickhouse cluster sink support

  #12999 commented on Jun 1, 2022 • 1 new comment

• [Issue 12844][pulsar-client-cpp] Excessive locking cause significant performance degradation

  #13079 commented on May 31, 2022 • 1 new comment

• [pulsar-broker] support broker isolation for uniform load shedder strategy

  #13080 commented on May 31, 2022 • 1 new comment

• [Issue 13060][security] Failed to evaluate client token: javax.security.sasl.SaslException: Final handshake step failed

  #13081 commented on May 31, 2022 • 1 new comment

• Trigger a build for branch-2.8 to see if the build passes

  #13122 commented on May 31, 2022 • 1 new comment

• [Issue 13129] [pulsar-metadata] Add watchdog thread in metadata store and track long running tasks.

  #13130 commented on May 31, 2022 • 1 new comment

• When the traffic to be unloaded is too small, it means that maxThroug…

  #13140 commented on May 31, 2022 • 1 new comment

• [Broker] Add admin api to get bundle stats

  #13184 commented on May 30, 2022 • 1 new comment

• [pulsar-broker] Support of TopicLifecyclePolicies REST handler.

  #13195 commented on May 30, 2022 • 1 new comment

• [Functions] Enable poolMessages of functions by default

  #13254 commented on May 30, 2022 • 1 new comment

• [Java Client] Fix DLQ message can not send when enable poolMessages

  #13280 commented on May 30, 2022 • 1 new comment

• [11646][Pulsar Java client] Fix ConfigurationDataUtils loadConf strategy

  #13298 commented on May 30, 2022 • 1 new comment

• [Issue 10816][Proxy] Refresh client auth token

  #13339 commented on May 30, 2022 • 1 new comment

• Fix maven.restlet.org repository does not download jar packages

  #13350 commented on May 29, 2022 • 1 new comment

• [Schema] Display null fields in SchemaInfo

  #13384 commented on May 29, 2022 • 1 new comment

• [Issue 13220][blog] Publishing a community blog for Pulsar's 10k+ GitHub Stars milestone

  #13438 commented on May 29, 2022 • 1 new comment

• [kafka-connect-adaptor] Map headers to properties when converting a record

  #13458 commented on May 29, 2022 • 1 new comment

• [broker]loadBalancerMemoryResourceWeight config default value optimiz…

  #13464 commented on May 29, 2022 • 1 new comment

• [Build] fix python client build failure on apline

  #13485 commented on May 29, 2022 • 1 new comment

• repeat registration when unload a bundle

  #13537 commented on May 29, 2022 • 1 new comment

• [PIP-129] Introduce intermediate state for ledger deletion

  #13575 commented on May 29, 2022 • 1 new comment

• Fix - Cancel connect task when replicator disconnect after connect failed.

  #13602 commented on May 29, 2022 • 1 new comment

• [Issue 13559] Offload compacted ledger into tiered storage

  #13680 commented on May 29, 2022 • 1 new comment

• Collect broker dispatch latency in prometheus

  #13681 commented on May 29, 2022 • 1 new comment

• docker-compose: Fix startup issues on SELinux

  #13708 commented on May 29, 2022 • 1 new comment

• Bump prometheus client version from 0.5.0 to 0.15.0

  #13785 commented on Jun 3, 2022 • 1 new comment

• [Issue 14013][broker]make internalPeekNthMessage method async

  #14039 commented on Jun 3, 2022 • 1 new comment

• [Issue 14013][broker] make getStats method async

  #14048 commented on Jun 3, 2022 • 1 new comment

• Fix bug: markdelete position not moving forward when skipping lost entries

  #14645 commented on Jun 4, 2022 • 1 new comment

• make `setMessageRoutingMode` method more readable and optimize unit test for `messageRoutingMode`

  #14726 commented on Jun 1, 2022 • 1 new comment

• [fix] [package] Fix Auto delete the package name issue

  #14792 commented on May 30, 2022 • 1 new comment

• [improve][security] Add load multiple certificates support

  #14798 commented on May 30, 2022 • 1 new comment

• Enable TCP/IP keepalive by default for broker, proxy and client

  #14841 commented on May 30, 2022 • 1 new comment

• [Fix][Doc] Remove the Pulsar Manager Pod and Service from output

  #14913 commented on May 30, 2022 • 1 new comment

• [cleanup][pom.xml] Could org.apache.pulsar:buildtools:2.10.0-SNAPSHOT drop off redundant dependencies?

  #14924 commented on Jun 3, 2022 • 1 new comment

• [Pulsar SQL] Upgrade Presto version to 334 to support Java 11.0.14.1

  #14953 commented on Jun 2, 2022 • 1 new comment

• [fix][broker] The offline consumer is not removed from the consumerList

  #14970 commented on Jun 2, 2022 • 1 new comment

• [Authenticate] optimization getHostName correct when use broker ip in Kerberos authentication

  #15129 commented on Jun 2, 2022 • 1 new comment

• Upgrade async-http-client to 2.12.3

  #15214 commented on May 29, 2022 • 1 new comment

• [function] refine file io connector

  #15250 commented on Jun 3, 2022 • 1 new comment

• [improve][tx] enhance validation when updating transaction topic

  #15301 commented on Jun 2, 2022 • 1 new comment

• [improve][client] Should use CompletableFuture#get(long, TimeUnit)

  #15321 commented on Jun 4, 2022 • 1 new comment

• [fix] [broker] Disabled deduplication, but ledger-store will not be d…

  #15363 commented on Jun 4, 2022 • 1 new comment

• [improve][doc] Deduplication can have effects in performance and is not activated at client level

  #15368 commented on Jun 1, 2022 • 1 new comment

• [PIP-159][Improve][txn]Reuse transaction buffer reader

  #15378 commented on May 30, 2022 • 1 new comment

• [fix][Broker] NarUnpacker create directory and file without permission check

  #15412 commented on Jun 2, 2022 • 1 new comment

• [feat][elasticsearch-sink] Option to strip out non printable characters

  #15431 commented on May 30, 2022 • 1 new comment

• [fix] Ensure resources are disposed in a sync way while closing ManagedLedgerFactory and CoordinationService

  #15638 commented on Jun 3, 2022 • 1 new comment

• [Revert] [#15483] Remove sensitive msg from consumer/producer stats log

  #15817 commented on Jun 3, 2022 • 1 new comment

• [improve][cpp-client] Add basic authentication

  #15822 commented on May 31, 2022 • 1 new comment

• [DISCUSS] Gather missing permission granularity

  #15711 commented on May 30, 2022 • 0 new comments

• [PIP-160] ManagedLedger decorator for batch append enties

  #15370 commented on May 30, 2022 • 0 new comments

• Refactor doc Bot

  #15797 commented on May 30, 2022 • 0 new comments

• PIP-158: Split client TLS transport encryption from authentication

  #15289 commented on Jun 1, 2022 • 0 new comments

• PIP-166: Function add `MANUAL` delivery semantics

  #15560 commented on Jun 2, 2022 • 0 new comments

• [fix][txn] Transaction cumulative ack redeliver change

  #14371 commented on May 30, 2022 • 0 new comments

• [feature][broker] Add new load manager strategy for load manager to select broker having load below average.

  #14971 commented on May 31, 2022 • 0 new comments

• [improve][tiered storage] Reduce cpu usage when offloading the ledger

  #15063 commented on Jun 1, 2022 • 0 new comments

• [feature][transaction] Add a configuration to control max active transaction of coordinator

  #15157 commented on May 30, 2022 • 0 new comments

• [feat][elasticsearch] Add hashed id support

  #15428 commented on May 30, 2022 • 0 new comments

• [cleanup][dependency] Remove JUnit

  #15616 commented on May 30, 2022 • 0 new comments

• [broker][monitoring] add message ack rate metric for consumer

  #15674 commented on Jun 2, 2022 • 0 new comments

• [fix][metrics] fixed ProxyStats to use common.stats.JvmMetrics

  #15692 commented on Jun 3, 2022 • 0 new comments

• [fix][security] Add timeout of sync methods and avoid call sync method for AuthoriationService

  #15694 commented on Jun 3, 2022 • 0 new comments

• [fix][broker]Fast return if ack cumulative illegal

  #15695 commented on Jun 2, 2022 • 0 new comments

• [Improve][doc] Add config of NAR extraction directory for the broker configuration

  #15778 commented on May 31, 2022 • 0 new comments

• [improve][doc] Add docs about isolation deployments and separate task topics

  #15802 commented on May 30, 2022 • 0 new comments

• Add new draft of architecture-overview.md and accompanying images

  #15809 commented on Jun 3, 2022 • 0 new comments

• [fix][broker] Avoid using `thenAccept` invoke async method.

  #15811 commented on Jun 1, 2022 • 0 new comments