commits  

Messages by Thread

• [I] [bug][broker] Broker interceptor (NAR) causes HTTP 400 FAIL_ON_TRAILING_TOKENS on admin API calls in 4.0.12 [pulsar] via GitHub
  • Re: [I] [bug][broker] Broker interceptor (NAR) causes HTTP 400 FAIL_ON_TRAILING_TOKENS on admin API calls in 4.0.12 [pulsar] via GitHub
• (pulsar-client-cpp) branch main updated: [improve] Refactor processMessageChunk to handle ack holes and out-of-order chunks (#587) zike
• (pulsar-site) branch asf-site-next updated: Site updated at revision 48f5c7c6faa2 github-bot
• (pulsar-site) branch main updated: Adding Pulsar Helm Chart 4.7.0 to index.yaml lhotari
• (pulsar-helm-chart) annotated tag pulsar-4.7.0 updated (de7be31 -> e822268) lhotari
• svn commit: r85905 - dev/pulsar/helm-chart/4.7.0-candidate-1 lhotari
• svn commit: r85906 - dev/pulsar/helm-chart/4.7.0-candidate-1 release/pulsar/helm-chart/4.7.0 lhotari
• [PR] Fix `getEstimatedSizeSinceMarkDeletePosition` throw `IllegalArgumentException` [pulsar] via GitHub
  • Re: [PR] [fix][broker] Fix `getEstimatedSizeSinceMarkDeletePosition` throw `IllegalArgumentException` [pulsar] via GitHub
• (pulsar) branch branch-4.2 updated: [improve][monitor][branch-4.2] Upgrade OpenTelemetry libraries (#26182) baodi
• [PR] [improve][broker] Optimize SegmentedLongArray with heap-backed long[][] [pulsar] via GitHub
• [PR] [improve][monitor][branch-4.2] Upgrade OpenTelemetry libraries [pulsar] via GitHub
  • Re: [PR] [improve][monitor][branch-4.2] Upgrade OpenTelemetry libraries [pulsar] via GitHub
• (pulsar) branch branch-4.0 updated: [improve][monitor][branch-4.0] Upgrade OpenTelemetry libraries (#26165) baodi
• (pulsar-client-cpp) branch main updated: Fix CI workflow by updating docker/build-push-action to ASF allowlisted version (#602) mmerli
• [PR] [fix][ci] Update docker/build-push-action to ASF allowlisted version [pulsar-client-cpp] via GitHub
  • Re: [PR] [fix][ci] Update docker/build-push-action to ASF allowlisted version [pulsar-client-cpp] via GitHub
• [D] Formal proof of ACK temporal collision in Shared subscription with TLA+ and chaos cross-validation [pulsar] via GitHub
  • Re: [D] Formal proof of ACK temporal collision in Shared subscription with TLA+ and chaos cross-validation [pulsar] via GitHub
  • Re: [D] Formal proof of ACK temporal collision in Shared subscription with TLA+ and chaos cross-validation [pulsar] via GitHub
• [PR] [fix][broker] Restore PendingAcksMap#get binary compatibility [pulsar] via GitHub
  • Re: [PR] [fix][broker] Restore PendingAcksMap#get binary compatibility [pulsar] via GitHub
  • Re: [PR] [fix][broker] Restore PendingAcksMap#get binary compatibility [pulsar] via GitHub
  • Re: [PR] [fix][broker] Restore PendingAcksMap#get binary compatibility [pulsar] via GitHub
  • Re: [PR] [fix][broker] Restore PendingAcksMap#get binary compatibility [pulsar] via GitHub
• Re: [PR] [fix][client] Fix waiting lookup requests not dispatched on timeout in ClientCnx [pulsar] via GitHub
• (pulsar-connectors) branch master updated: feat(kinesis): add message key mode for Kinesis records (#35) rfu
• Re: [PR] [fix][admin] Allow defaultNumPartitions for non-partitioned autoTopicCreation override [pulsar] via GitHub
  • Re: [PR] [fix][admin] Allow defaultNumPartitions for non-partitioned autoTopicCreation override [pulsar] via GitHub
• (pulsar-connectors) branch master updated: feat(kafka): copy Pulsar properties to Kafka headers and support idempotence (#36) rfu
• [PR] [fix][broker] Prevent partition expansion from inheriting delayed-delivery bucket state [pulsar] via GitHub
  • Re: [PR] [fix][broker] Prevent partition expansion from inheriting delayed-delivery bucket state [pulsar] via GitHub
  • Re: [PR] [fix][broker] Prevent partition expansion from inheriting delayed-delivery bucket state [pulsar] via GitHub
  • Re: [PR] [fix][broker] Prevent partition expansion from inheriting delayed-delivery bucket state [pulsar] via GitHub
• [I] [Bug] Partition expansion copies delayed-delivery bucket state to new partitions [pulsar] via GitHub
• [PR] [fix][cli] Fix V5 scalable-topics property parsing [pulsar] via GitHub
• [I] [Bug][V5] scalable-topics CLI property option consumes positional arguments [pulsar] via GitHub
• [PR] [fix][common] Keep equal-load bundles addressable after sorting [pulsar] via GitHub
• [PR] [improve][io] Align the OpenMLDB module's forced protobuf with the platform version [pulsar-connectors] via GitHub
  • Re: [PR] [improve][io] Align the OpenMLDB module's forced protobuf with the platform version [pulsar-connectors] via GitHub
• (pulsar-connectors) branch master updated: [fix][io] Upgrade OpenMLDB client to 0.9.2 and add sink integration test (#105) davekj
• [PR] [fix][io] Upgrade OpenMLDB client to 0.9.2 and add sink integration test [pulsar-connectors] via GitHub
  • Re: [PR] [fix][io] Upgrade OpenMLDB client to 0.9.2 and add sink integration test [pulsar-connectors] via GitHub
  • Re: [PR] [fix][io] Upgrade OpenMLDB client to 0.9.2 and add sink integration test [pulsar-connectors] via GitHub
• (pulsar-connectors) branch master updated: [improve][test] Add HBase sink integration test (#104) davekj
• [PR] [improve][test] Add HBase sink integration test [pulsar-connectors] via GitHub
  • Re: [PR] [improve][test] Add HBase sink integration test [pulsar-connectors] via GitHub
  • Re: [PR] [improve][test] Add HBase sink integration test [pulsar-connectors] via GitHub
• (pulsar-connectors) branch master updated: [fix][io] Flush and sync before closing the HDFS text sink stream (#100) davekj
• (pulsar-connectors) branch master updated: [improve][test] Bound container startup in all Testcontainers tests (#103) davekj
• [PR] [improve][test] Bound container startup in all Testcontainers tests [pulsar-connectors] via GitHub
  • Re: [PR] [improve][test] Bound container startup in all Testcontainers tests [pulsar-connectors] via GitHub
• (pulsar-connectors) branch master updated: [fix][io] Pin opentelemetry-semconv to a version the HBase client can use (#102) davekj
• [PR] [fix][io] Pin opentelemetry-semconv to a version the HBase client can use [pulsar-connectors] via GitHub
  • Re: [PR] [fix][io] Pin opentelemetry-semconv to a version the HBase client can use [pulsar-connectors] via GitHub
• [I] [Bug] HBase sink throws NoClassDefFoundError (opentelemetry-semconv 1.37.0 removed SemanticAttributes) [pulsar-connectors] via GitHub
  • Re: [I] [Bug] HBase sink throws NoClassDefFoundError (opentelemetry-semconv 1.37.0 removed SemanticAttributes) [pulsar-connectors] via GitHub
• [PR] [fix][io] Flush and sync before closing the HDFS text sink stream [pulsar-connectors] via GitHub
  • Re: [PR] [fix][io] Flush and sync before closing the HDFS text sink stream [pulsar-connectors] via GitHub
  • Re: [PR] [fix][io] Flush and sync before closing the HDFS text sink stream [pulsar-connectors] via GitHub
• (pulsar-connectors) branch master updated: [improve][test] Add HDFS3 sink integration test against MiniDFSCluster (#93) davekj
• (pulsar-connectors) branch master updated: [improve][test] Add Aerospike sink integration test (#96) davekj
• Re: [I] Flaky-test: PulsarDebeziumSourcesTest.testDebeziumPostgreSqlSource [pulsar] via GitHub
• Re: [I] Flaky-test: PulsarDebeziumOracleSourceTest.testDebeziumOracleDbSource [pulsar] via GitHub
• Re: [I] [Bug] KafkaAbstractSource consumer thread fatal error is silently lost when instance thread is blocked in sendOutputMessage() [pulsar] via GitHub
  • Re: [I] [Bug] KafkaAbstractSource consumer thread fatal error is silently lost when instance thread is blocked in sendOutputMessage() [pulsar] via GitHub
• Re: [I] [Bug] Potential OOM in FileSource due to unbounded LinkedBlockingQueue (UBSCQ) [pulsar] via GitHub
• [I] [Bug] Canal source client is incompatible with modern protobuf-java (NoSuchMethodError on connect) [pulsar-connectors] via GitHub
  • Re: [I] [Bug] Canal source client is incompatible with modern protobuf-java (NoSuchMethodError on connect) [pulsar-connectors] via GitHub
• [PR] [improve][test] Add Canal source integration test [pulsar-connectors] via GitHub
  • Re: [PR] [improve][test] Add Canal source integration test [pulsar-connectors] via GitHub
  • Re: [PR] [improve][test] Add Canal source integration test [pulsar-connectors] via GitHub
  • Re: [PR] [improve][test] Add Canal source integration test [pulsar-connectors] via GitHub
  • Re: [PR] [improve][test] Add Canal source integration test [pulsar-connectors] via GitHub
  • Re: [PR] [improve][test] Add Canal source integration test [pulsar-connectors] via GitHub
• [I] [Bug] Aerospike sink is completely non-functional: every write throws "Object serializer has been disabled" [pulsar-connectors] via GitHub
  • Re: [I] [Bug] Aerospike sink is completely non-functional: every write throws "Object serializer has been disabled" [pulsar-connectors] via GitHub
  • Re: [I] [Bug] Aerospike sink is completely non-functional: every write throws "Object serializer has been disabled" [pulsar-connectors] via GitHub
• [PR] [improve][test] Add Aerospike sink integration test [pulsar-connectors] via GitHub
  • Re: [PR] [improve][test] Add Aerospike sink integration test [pulsar-connectors] via GitHub
  • Re: [PR] [improve][test] Add Aerospike sink integration test [pulsar-connectors] via GitHub
• [PR] [improve][test] Add NSQ source integration test [pulsar-connectors] via GitHub
  • Re: [PR] [improve][test] Add NSQ source integration test [pulsar-connectors] via GitHub
  • Re: [PR] [improve][test] Add NSQ source integration test [pulsar-connectors] via GitHub
• [I] [Bug] HDFS3 sink close() calls hsync() on an already-closed stream (ClosedChannelException) [pulsar-connectors] via GitHub
  • Re: [I] [Bug] HDFS3 sink close() calls hsync() on an already-closed stream (ClosedChannelException) [pulsar-connectors] via GitHub
  • Re: [I] [Bug] HDFS3 sink close() calls hsync() on an already-closed stream (ClosedChannelException) [pulsar-connectors] via GitHub
• [PR] [improve][test] Add HDFS3 sink integration test against MiniDFSCluster [pulsar-connectors] via GitHub
  • Re: [PR] [improve][test] Add HDFS3 sink integration test against MiniDFSCluster [pulsar-connectors] via GitHub
  • Re: [PR] [improve][test] Add HDFS3 sink integration test against MiniDFSCluster [pulsar-connectors] via GitHub
  • Re: [PR] [improve][test] Add HDFS3 sink integration test against MiniDFSCluster [pulsar-connectors] via GitHub
• (pulsar-connectors) branch master updated: [fix][test] Bound MqttSinkIntegrationTest container startup so it cannot hang CI (#91) davekj
• (pulsar-connectors) branch master updated: [improve][ci] Shard the test job across three parallel runners (#92) davekj
• [PR] [improve][ci] Shard the test job across three parallel runners [pulsar-connectors] via GitHub
  • Re: [PR] [improve][ci] Shard the test job across three parallel runners [pulsar-connectors] via GitHub
• (pulsar-connectors) branch master updated: [fix][test] Replace fixed sleeps with Awaitility polls in sink tests (#86) davekj
• [PR] [fix][test] Bound MqttSinkIntegrationTest container startup so it cannot hang CI [pulsar-connectors] via GitHub
  • Re: [PR] [fix][test] Bound MqttSinkIntegrationTest container startup so it cannot hang CI [pulsar-connectors] via GitHub
  • Re: [PR] [fix][test] Bound MqttSinkIntegrationTest container startup so it cannot hang CI [pulsar-connectors] via GitHub
• [PR] [improve][io] Extend RabbitMQ source with queue and exchange options [pulsar-connectors] via GitHub
  • Re: [PR] [improve][io] Extend RMQ source with connection, queue and exchange options [pulsar-connectors] via GitHub
  • Re: [PR] [improve][io] Extend RMQ source with connection, queue and exchange options [pulsar-connectors] via GitHub
  • Re: [PR] [improve][io] Extend RMQ source with connection, queue and exchange options [pulsar-connectors] via GitHub
• [I] [Bug] MqttSinkIntegrationTest can hang the CI job for 45 minutes instead of failing [pulsar-connectors] via GitHub
  • Re: [I] [Bug] MqttSinkIntegrationTest can hang the CI job for 45 minutes instead of failing [pulsar-connectors] via GitHub
• (pulsar-connectors) branch master updated: [fix][io] Interrupt Kafka Source instance thread on consumer fatal error to prevent deadlock (#88) davekj
• [PR] [fix][broker] Prevent stale read completions from stranding Failover subscriptions [pulsar] via GitHub
  • Re: [PR] [fix][broker] Prevent stale read completions from stranding Failover subscriptions [pulsar] via GitHub
  • Re: [PR] [fix][broker] Prevent stale read completions from stranding Failover subscriptions [pulsar] via GitHub
• (pulsar-connectors) branch master updated: [fix][io] jdbc: drain flush() iteratively to avoid StackOverflowError under sustained backlog (#39) davekj
• (pulsar-connectors) branch master updated: [fix][test] Wait for the public tenant before creating the test namespace (#84) davekj
• (pulsar-connectors) branch master updated: [improve][test] Add DynamoDB source integration test (#77) davekj
• (pulsar) branch master updated: [improve][broker] PIP-486 (PR4): bucket-shared consumption for scale-up fan-out (#26173) mmerli
• (pulsar) branch master updated: [fix][client] Scalable topics: stream consumer must not acknowledge on close or topic-removal (#26172) mmerli
• (pulsar-connectors) branch master updated: [fix][io] Fix DynamoDB source client construction with a custom endpoint (#79) davekj
• [PR] [improve][io] Add queue options, exchange binding and message propert… [pulsar-connectors] via GitHub
  • Re: [PR] [improve][io] Add queue options, exchange binding and message propert… [pulsar-connectors] via GitHub
• (pulsar-helm-chart) branch master updated: Use pulsar.zookeeper.connect template in bookkeeper cluster initialize command. (#707) lhotari
• [PR] [fix][test] Replace fixed sleeps with Awaitility polls in sink tests [pulsar-connectors] via GitHub
  • Re: [PR] [fix][test] Replace fixed sleeps with Awaitility polls in sink tests [pulsar-connectors] via GitHub
  • Re: [PR] [fix][test] Replace fixed sleeps with Awaitility polls in sink tests [pulsar-connectors] via GitHub
• [I] [Bug] Sink tests race their sinks' async flush: fixed Thread.sleep before verify() [pulsar-connectors] via GitHub
  • Re: [I] [Bug] Sink tests race their sinks' async flush: fixed Thread.sleep before verify() [pulsar-connectors] via GitHub
• [PR] [fix][test] Wait for the public tenant before creating the test namespace [pulsar-connectors] via GitHub
  • Re: [PR] [fix][test] Wait for the public tenant before creating the test namespace [pulsar-connectors] via GitHub
• [I] [Bug] Flaky test: PulsarSchemaHistoryTest.setup fails with 'Tenant does not exist' [pulsar-connectors] via GitHub
  • Re: [I] [Bug] Flaky test: PulsarSchemaHistoryTest.setup fails with 'Tenant does not exist' [pulsar-connectors] via GitHub
• (pulsar-connectors) branch master updated: [fix][io] Prevent OOM in FileSource by bounding internal queues (#82) davekj
• (pulsar) branch master updated: [fix][broker] Remove lock contention in delayed delivery stats read paths (#25990) zixuan
• (pulsar) branch master updated: [fix][broker] Fix bucket delayed message index metrics reset on scrape (#26171) zixuan
• (pulsar) branch master updated: [fix][broker] Fix BucketDelayedDeliveryTracker recovery after LightProto migration (#26160) zixuan
• Re: [PR] [improve][api] Add Builder Methods to Create Message-based TableView [pulsar] via GitHub
  • Re: [PR] [improve][api] Add Builder Methods to Create Message-based TableView [pulsar] via GitHub
• [PR] [improve][broker] PIP-486 (PR4): bucket-shared consumption for scale-up fan-out [pulsar] via GitHub
  • Re: [PR] [improve][broker] PIP-486 (PR4): bucket-shared consumption for scale-up fan-out [pulsar] via GitHub
• (pulsar-connectors) branch master updated: [fix][io] Do not drop files when the work queue rejects an offer (#81) davekj
• (pulsar-connectors) branch master updated: [improve][test] Add Kafka source and sink integration tests (#76) davekj
• (pulsar-connectors) branch master updated: Set up default protection ruleset for default and release branches (#25) davekj
• Re: [PR] [INFRA] Set up default rulesets for default and release branches [pulsar-connectors] via GitHub
• Re: [I] File connector: Some file listing loop runs might be skipped [pulsar-connectors] via GitHub
• Re: [PR] [fix][io] Fix skipped file listing loop runs in file connector [pulsar-connectors] via GitHub
• (pulsar-connectors) branch master updated: [fix][io] Fix skipped file listing loop runs in file connector (#14) davekj
• [PR] [fix][io] Do not drop files when the work queue rejects an offer [pulsar-connectors] via GitHub
  • Re: [PR] [fix][io] Do not drop files when the work queue rejects an offer [pulsar-connectors] via GitHub
  • Re: [PR] [fix][io] Do not drop files when the work queue rejects an offer [pulsar-connectors] via GitHub
  • Re: [PR] [fix][io] Do not drop files when the work queue rejects an offer [pulsar-connectors] via GitHub
• [I] [Bug] Bounding the file connector's work queue (#28) would silently drop files against current master [pulsar-connectors] via GitHub
  • Re: [I] [Bug] Bounding the file connector's work queue (#28) would silently drop files against current master [pulsar-connectors] via GitHub
• (pulsar-connectors) branch master updated: [improve][test] Add Solr sink integration test (#75) davekj
• [PR] [fix][io] Fix DynamoDB source client construction with a custom endpoint [pulsar-connectors] via GitHub
  • Re: [PR] [fix][io] Fix DynamoDB source client construction with a custom endpoint [pulsar-connectors] via GitHub
  • Re: [PR] [fix][io] Fix DynamoDB source client construction with a custom endpoint [pulsar-connectors] via GitHub
  • Re: [PR] [fix][io] Fix DynamoDB source client construction with a custom endpoint [pulsar-connectors] via GitHub
• [I] [Bug] DynamoDB source cannot use a custom endpoint: region and endpoint are both set, which AWS SDK v1 forbids [pulsar-connectors] via GitHub
  • Re: [I] [Bug] DynamoDB source cannot use a custom endpoint: region and endpoint are both set, which AWS SDK v1 forbids [pulsar-connectors] via GitHub
• [PR] [improve][test] Add DynamoDB source integration test [pulsar-connectors] via GitHub
  • Re: [PR] [improve][test] Add DynamoDB source integration test [pulsar-connectors] via GitHub
  • Re: [PR] [improve][test] Add DynamoDB source integration test [pulsar-connectors] via GitHub
  • Re: [PR] [improve][test] Add DynamoDB source integration test [pulsar-connectors] via GitHub
  • Re: [PR] [improve][test] Add DynamoDB source integration test [pulsar-connectors] via GitHub
• [PR] [improve][test] Add Kafka source and sink integration tests [pulsar-connectors] via GitHub
  • Re: [PR] [improve][test] Add Kafka source and sink integration tests [pulsar-connectors] via GitHub
  • Re: [PR] [improve][test] Add Kafka source and sink integration tests [pulsar-connectors] via GitHub
• [PR] [improve][test] Add Solr sink integration test [pulsar-connectors] via GitHub
  • Re: [PR] [improve][test] Add Solr sink integration test [pulsar-connectors] via GitHub
  • Re: [PR] [improve][test] Add Solr sink integration test [pulsar-connectors] via GitHub
• [PR] [improve][ci] Run the integrationTest source set in CI [pulsar-connectors] via GitHub
  • Re: [PR] [improve][ci] Run the integrationTest source set in CI [pulsar-connectors] via GitHub
• (pulsar-connectors) branch master updated: [doc][io] List the Debezium MariaDB source in the README connector table (#72) davekj
• (pulsar-connectors) branch master updated: [fix][test] Bound record reads in Debezium MySQL and Postgres tests (#71) davekj
• [PR] [improve][test] Add InfluxDB v2 sink integration test and deflake the mock test [pulsar-connectors] via GitHub
  • Re: [PR] [improve][test] Add InfluxDB v2 sink integration test and deflake the mock test [pulsar-connectors] via GitHub
  • Re: [PR] [improve][test] Add InfluxDB v1 and v2 sink integration tests, deflake the v2 mock test [pulsar-connectors] via GitHub
• [PR] [doc][io] List the Debezium MariaDB source in the README connector table [pulsar-connectors] via GitHub
  • Re: [PR] [doc][io] List the Debezium MariaDB source in the README connector table [pulsar-connectors] via GitHub
• (pulsar-connectors) branch master updated: [feat][io] Add Debezium MariaDB source connector (#69) davekj
• (pulsar-connectors) branch master updated: [improve][test] Add Debezium MongoDB source integration test (#58) davekj
• [PR] [fix][test] Bound record reads in Debezium MySQL and Postgres tests [pulsar-connectors] via GitHub
  • Re: [PR] [fix][test] Bound record reads in Debezium MySQL and Postgres tests [pulsar-connectors] via GitHub
  • Re: [PR] [fix][test] Bound record reads in Debezium MySQL and Postgres tests [pulsar-connectors] via GitHub
• [I] [Bug] Debezium integration tests can hang CI for 45 minutes instead of failing [pulsar-connectors] via GitHub
  • Re: [I] [Bug] Debezium integration tests can hang CI for 45 minutes instead of failing [pulsar-connectors] via GitHub
• Re: [I] Flaky test: ProcessedFileThreadTest.renameFileTest [pulsar-connectors] via GitHub
• (pulsar-connectors) branch master updated: [fix][io] Fix duplicate file offers and flaky tests in file connector (#41) davekj
• (pulsar-connectors) branch master updated: [improve][io] Upgrade Debezium to 3.4.3.Final (#64) davekj
• [PR] [feat][io] Add Debezium MariaDB source connector [pulsar-connectors] via GitHub
  • Re: [PR] [feat][io] Add Debezium MariaDB source connector [pulsar-connectors] via GitHub
• (pulsar-connectors) branch master updated: [improve][test] Add MariaDB JDBC sink integration test (#59) davekj
• [I] [feat][io] Add Debezium Spanner source connector [pulsar-connectors] via GitHub
• [I] [feat][io] Add Debezium CockroachDB source connector [pulsar-connectors] via GitHub
• [I] [feat][io] Add Debezium Db2 source connector [pulsar-connectors] via GitHub
• [I] [feat][io] Add Debezium MariaDB source connector [pulsar-connectors] via GitHub
  • Re: [I] [feat][io] Add Debezium MariaDB source connector [pulsar-connectors] via GitHub
• [PR] [improve][io] Upgrade Debezium to 3.4.3.Final [pulsar-connectors] via GitHub
  • Re: [PR] [improve][io] Upgrade Debezium to 3.4.3.Final [pulsar-connectors] via GitHub
• [I] [improve][io] Migrate Debezium from the 3.4.x line to 3.6.0.Final [pulsar-connectors] via GitHub
• (pulsar) branch branch-4.2 updated: [fix][sec][branch-4.2] Upgrade Netty to 4.1.136.Final (#26168) mmerli
• (pulsar) branch branch-4.0 updated: [fix][sec][branch-4.0] Upgrade Netty to 4.1.136.Final (#26170) mmerli
• [PR] [improve][test] Add Debezium Oracle source integration test [pulsar-connectors] via GitHub

• Earlier messages