Insights: apache/pulsar
Overview
Could not load contribution data
Please try again later
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 -
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 -
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 -
[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