dev  

Messages by Thread

• [jira] [Resolved] (KAFKA-17898) Seperate Epoch Bump Scenarios and Error Handling in TV2 Justine Olshan (Jira)
  • Re: [jira] [Resolved] (KAFKA-17898) Seperate Epoch Bump Scenarios and Error Handling in TV2 Swikar Patel
• Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.7 #211 Apache Jenkins Server
  • Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.7 #212 Apache Jenkins Server
• Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.9 #118 Apache Jenkins Server
  • Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.9 #119 Apache Jenkins Server
• [jira] [Created] (KAFKA-18088) Add consumer metric about paused partitions Matthias J. Sax (Jira)
• [jira] [Created] (KAFKA-18087) Revert unnecessary integration testing of Consumers using both group protocols Kirk True (Jira)
• [jira] [Resolved] (KAFKA-18085) Abort inflight requests when rebootstrapping due to timeout or error Rajini Sivaram (Jira)
• [jira] [Resolved] (KAFKA-18011) Remove ZooKeeper from the docs Chia-Ping Tsai (Jira)
• Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.8 #115 Apache Jenkins Server
  • Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.8 #116 Apache Jenkins Server
  • Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.8 #117 Apache Jenkins Server
  • Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.8 #118 Apache Jenkins Server
  • Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.8 #119 Apache Jenkins Server
• [jira] [Created] (KAFKA-18086) Enable propagation of the error message when writing state Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-18077) Remove deprecated JmxReporter(String) Chia-Ping Tsai (Jira)
• Optimize KafkaProducer Performance giri mungi
  • Re: Optimize KafkaProducer Performance Haruki Okada
• [jira] [Resolved] (KAFKA-18045) Add 0.11, 1.0, 1.1, and 2.0 back to streams_upgrade_test.py Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-18085) Abort inflight requests when rebootstrapping due to timeout or error Rajini Sivaram (Jira)
• [jira] [Created] (KAFKA-18084) Null and leaked AcquisitionLockTimerTask causes hanging AcknowledgeRequest and corrupted state of batch Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-17988) Fix flaky ReconfigurableQuorumIntegrationTest.testRemoveAndAddSameController Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-17835) Move ProducerIdManager and RPCProducerIdManager to transaction-coordinator module Jira
• [jira] [Created] (KAFKA-18083) ClusterInstance custom controllerListener not work Kuan Po Tseng (Jira)
• [jira] [Created] (KAFKA-18082) Add 0.11, 1.0, 1.1 and 2.0 to consumer upgrade e2e Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-18078) Fix failed MetricsTest.testJMXFilter Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-18075) Prevent ClusterInstance default producer and consumer initialization with empty configs Chia-Ping Tsai (Jira)
• Plz help on kafka consumer API performance(taking time on the first consumer.poll()) giri mungi
  • Re: Plz help on kafka consumer API performance(taking time on the first consumer.poll()) PoAn Yang
  • Re: Plz help on kafka consumer API performance(taking time on the first consumer.poll()) giri mungi
  • Re: Plz help on kafka consumer API performance(taking time on the first consumer.poll()) giri mungi
  • Re: Plz help on kafka consumer API performance(taking time on the first consumer.poll()) giri mungi
  • Re: Plz help on kafka consumer API performance(taking time on the first consumer.poll()) Chia-Ping Tsai
  • Re: Plz help on kafka consumer API performance(taking time on the first consumer.poll()) giri mungi
  • Re: Plz help on kafka consumer API performance(taking time on the first consumer.poll()) giri mungi
  • Re: Plz help on kafka consumer API performance(taking time on the first consumer.poll()) Chia-Ping Tsai
  • Re: Plz help on kafka consumer API performance(taking time on the first consumer.poll()) giri mungi
  • Re: Plz help on kafka consumer API performance(taking time on the first consumer.poll()) Chia-Ping Tsai
  • Re: Plz help on kafka consumer API performance(taking time on the first consumer.poll()) giri mungi
  • Re: Plz help on kafka consumer API performance(taking time on the first consumer.poll()) Chia-Ping Tsai
  • Re: Plz help on kafka consumer API performance(taking time on the first consumer.poll()) giri mungi
  • Re: Plz help on kafka consumer API performance(taking time on the first consumer.poll()) Chia-Ping Tsai
  • Re: Plz help on kafka consumer API performance(taking time on the first consumer.poll()) giri mungi
  • Re: Plz help on kafka consumer API performance(taking time on the first consumer.poll()) giri mungi
• Build failed in Jenkins: Kafka » kafka-2.7-jdk8 #197 Apache Jenkins Server
• [jira] [Resolved] (KAFKA-16734) Add support for formatting records written to share-group state topic in kafka-dump-log.sh Andrew Schofield (Jira)
• [jira] [Created] (KAFKA-18081) Remove isKRaftTest from the kraft-only tests Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-18080) Replace DelayedItem by Long type Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-18076) Remove `isZkMigrationTest` and related code Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-18079) `consumer-config` does not work with console-share-consumer Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-18037) Remove deprecated methods from EmbeddedConnect and EmbeddedConnectCluster Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-18078) Fix failed MetricsTest.testJMXFilter Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-18077) Remove deprecated JmxReporter(String) Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-18076) Remove `isZkMigrationTest` and related code Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-18075) Prevent ClusterInstance default producer and consumer initialization with empty configs Kuan Po Tseng (Jira)
• [jira] [Created] (KAFKA-18074) Add kafka client compatibility matrix Chia-Ping Tsai (Jira)
• Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #126 Apache Jenkins Server
• [jira] [Created] (KAFKA-18073) Data loss when Kafka Connect retriable exception raised Tom Thornton (Jira)
• [jira] [Resolved] (KAFKA-18051) Disallow creating ACLs with principals that do not contain a colon Colin McCabe (Jira)
• [jira] [Resolved] (KAFKA-18072) Data corruption in netty version to 4.1.111.Final Tom Thornton (Jira)
• [jira] [Created] (KAFKA-18072) Data corruption in netty version to 4.1.112.Final Tom Thornton (Jira)
• [jira] [Resolved] (KAFKA-18000) Fix flaky ReplicaManagerTest#testSuccessfulBuildRemoteLogAuxStateMetrics Mickael Maison (Jira)
• [jira] [Created] (KAFKA-18071) Avoid unneeded background event to refresh regex if no subscription pattern in use Lianet Magrans (Jira)
• [jira] [Resolved] (KAFKA-18059) kafka-metadata-quorum.sh add-controller subcommand can't recognize argument --config Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-18070) Update kafka-metadata-quorum.sh output in docs to match post-KIP-853 appearance Colin McCabe (Jira)
• [jira] [Resolved] (KAFKA-18065) be helpful when throwing ConcurrentModificationException out of consumers Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-18069) Out of order output from windowed aggregations Rhishikesh Joshi (Jira)
• [jira] [Created] (KAFKA-18068) Fixing typo in ProducerConfig Robert V (Jira)
• [jira] [Resolved] (KAFKA-17964) TransactionsTest.testSendOffsetsWithGroupId fails with CONSUMER group protocol Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-17961) TransactionsBounceTest.testWithGroupId fails with CONSUMER group protocol Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-12690) Remove deprecated Producer#sendOffsetsToTransaction Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-18067) Kafka Streams can leak Producer client under EOS A. Sophie Blee-Goldman (Jira)
• [jira] [Created] (KAFKA-18066) Misleading/mismatched StreamThread id in logging A. Sophie Blee-Goldman (Jira)
• [jira] [Created] (KAFKA-18065) be helpful when throwing ConcurrentModificationException out of consumers Chia-Ping Tsai (Jira)
• Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.8 #113 Apache Jenkins Server
• [jira] [Resolved] (KAFKA-17917) Convert Kafka core system tests to use KRaft Kevin Wu (Jira)
• [jira] [Resolved] (KAFKA-18063) SnapshotRegistry should not leak memory Colin McCabe (Jira)
• [DISCUSS] KIP-1115: Bazel Builds Vince Rose
  • Re: [DISCUSS] KIP-1115: Bazel Builds Chia-Ping Tsai
  • Re: [DISCUSS] KIP-1115: Bazel Builds Gaurav Narula
  • Re: [DISCUSS] KIP-1115: Bazel Builds Viktor Somogyi-Vass
  • Re: [DISCUSS] KIP-1115: Bazel Builds Vince Rose
  • Re: [DISCUSS] KIP-1115: Bazel Builds Farid Zakaria
  • Re: [DISCUSS] KIP-1115: Bazel Builds Vince Rose
  • Re: [DISCUSS] KIP-1115: Bazel Builds David Arthur
  • Re: [DISCUSS] KIP-1115: Bazel Builds Farid Zakaria
  • Re: [DISCUSS] KIP-1115: Bazel Builds Vince Rose
  • Re: [DISCUSS] KIP-1115: Bazel Builds Bruno Cadonna
  • Re: [DISCUSS] KIP-1115: Bazel Builds Chia-Ping Tsai
• Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.9 #114 Apache Jenkins Server
  • Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.9 #115 Apache Jenkins Server
  • Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.9 #116 Apache Jenkins Server
• [jira] [Resolved] (KAFKA-18038) Flaky StreamThreadTest shouldLogAndRecordSkippedRecordsForInvalidTimestamps Matthias J. Sax (Jira)
• [jira] [Created] (KAFKA-18064) SASL SCRAM should throw exception on wrap/unwrap Istvan Toth (Jira)
• Re: [DISCUSS] KIP-1022 Formatting and Updating Features Justine Olshan
• [jira] [Created] (KAFKA-18063) SnapshotRegistry should not leak memory Colin McCabe (Jira)
• [PR] MINOR: Add alive stream threads to Kafka Streams metrics [kafka-site] via GitHub
  • Re: [PR] MINOR: Add alive stream threads to Kafka Streams metrics [kafka-site] via GitHub
• [jira] [Created] (KAFKA-18062) Use feature version to enable ELR Calvin Liu (Jira)
• [jira] [Resolved] (KAFKA-17638) Add support for Java 23 Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-17640) Document Java 23 support and include release note Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-18061) AddRaftVoter responds with error message "NONE" instead of null Anton Agestam (Jira)
• [jira] [Created] (KAFKA-18056) Minor : Fix a bug related to updating the callbacks after commitAsync. Shivsundar R (Jira)
• [jira] [Created] (KAFKA-18060) new coordinator does not support v0-v2 TxnOffsetCommitRequest when using CONSUMER group Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-18059) kafka-metadata-quorum.sh add-controller subcommand can't recognize argument --config PoAn Yang (Jira)
• [jira] [Created] (KAFKA-18058) Integrate offset cleanup algorithm with share coordinator Sushant Mahajan (Jira)
• [jira] [Created] (KAFKA-18057) Algorithm to calculate redundant interval of offsets for cleanup Sushant Mahajan (Jira)
• [jira] [Created] (KAFKA-18054) Automatically detect missed configs needed by a topology A. Sophie Blee-Goldman (Jira)
• [jira] [Created] (KAFKA-18055) Remove TopologyConfig and clean up Topology/StreamsBuilder config APIs A. Sophie Blee-Goldman (Jira)
• [jira] [Created] (KAFKA-18053) Clean up TopologyConfig and API for supplying configs needed by the topology A. Sophie Blee-Goldman (Jira)
• Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #124 Apache Jenkins Server
• [jira] [Resolved] (KAFKA-18019) Convert INVALID_PRODUCER_ID_MAPPING from abortable error to fatal error Jeff Kim (Jira)
• [jira] [Resolved] (KAFKA-18044) Test ticket for INFRA A. Sophie Blee-Goldman (Jira)
• [jira] [Created] (KAFKA-18052) Decouple the dependency of feature stable version to the metadata version Dongnuo Lyu (Jira)
• [jira] [Created] (KAFKA-18051) Disallow creating ACLs with principals that do not contain a colon Colin McCabe (Jira)
• [DISCUSS] PR workflow David Arthur
  • Re: [DISCUSS] PR workflow Matthias J. Sax
  • Re: [DISCUSS] PR workflow David Arthur
  • Re: [DISCUSS] PR workflow Ukpa Uchechi
  • Re: [DISCUSS] PR workflow David Arthur
  • Re: [DISCUSS] PR workflow Ukpa Uchechi
• [DISCUSS] KIP-1113: Enhancements to Rack-Aware Partition Assignor for Improved Client-Side Independence and Load Balancing Jerry Cai
• [jira] [Resolved] (KAFKA-18027) MINOR: Correct DelayedOperationPurgatory code around adding of an already completed operation Jun Rao (Jira)
• [DISCUSS] Java 23 Support for 3.9.x Greg Harris
  • Re: [DISCUSS] Java 23 Support for 3.9.x David Arthur
  • Re: [DISCUSS] Java 23 Support for 3.9.x Greg Harris
  • Re: [DISCUSS] Java 23 Support for 3.9.x Chia-Ping Tsai
  • Re: [DISCUSS] Java 23 Support for 3.9.x Josep Prat
  • Re: [DISCUSS] Java 23 Support for 3.9.x Anton Agestam
  • Re: [DISCUSS] Java 23 Support for 3.9.x Ismael Juma
  • Re: [DISCUSS] Java 23 Support for 3.9.x Greg Harris
  • Re: [DISCUSS] Java 23 Support for 3.9.x Ismael Juma
  • Re: [DISCUSS] Java 23 Support for 3.9.x Greg Harris
  • Re: [DISCUSS] Java 23 Support for 3.9.x Greg Harris
  • Re: [DISCUSS] Java 23 Support for 3.9.x Swikar Patel
  • Re: [DISCUSS] Java 23 Support for 3.9.x Chia-Ping Tsai
  • Re: [DISCUSS] Java 23 Support for 3.9.x Greg Harris
  • Re: [DISCUSS] Java 23 Support for 3.9.x Luke Chen
  • Re: [DISCUSS] Java 23 Support for 3.9.x Divij Vaidya
  • Re: [DISCUSS] Java 23 Support for 3.9.x Greg Harris
  • Re: [DISCUSS] Java 23 Support for 3.9.x Mickael Maison
  • RE: [DISCUSS] Java 23 Support for 3.9.x Mateusz Gajewski
• [jira] [Resolved] (KAFKA-17721) Enable to configure listener name and protocol for controller Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-18050) Upgrade the checkstyle version to 10.20.1 Jira
• [jira] [Created] (KAFKA-18049) Update the caffeine version to 3.1.8 Jira
• [jira] [Created] (KAFKA-18047) Add org.apache.kafka.automatic.config.providers to System Properties section Mickael Maison (Jira)
• [jira] [Created] (KAFKA-18048) Consider to decouple AppEventHandler from ConsumerNetworkThread PoAn Yang (Jira)
• [jira] [Created] (KAFKA-18046) High CPU usage when using Log4j2 Anthony Maire (Jira)
• [jira] [Created] (KAFKA-18045) Add 0.11, 1.0, 1.1, and 2.0 back to streams_upgrade_test.py Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-18044) Test ticket for INFRA Gavin McDonald (Jira)
• [jira] [Resolved] (KAFKA-18043) Fix flaky test - StreamThreadTest: shouldLogAndRecordSkippedRecordsForInvalidTimestamps Abhinav Dixit (Jira)
• [jira] [Created] (KAFKA-18043) Fix flaky test - StreamThreadTest: shouldLogAndRecordSkippedRecordsForInvalidTimestamps Abhinav Dixit (Jira)
• Request permission to contribute De Gao
  • Re: Request permission to contribute Josep Prat
• [jira] [Resolved] (KAFKA-12689) Remove deprecated EOS configs Matthias J. Sax (Jira)
• [jira] [Reopened] (KAFKA-10409) Refactor Kafka Streams RocksDb iterators A. Sophie Blee-Goldman (Jira)
• [jira] [Resolved] (KAFKA-10409) Refactor Kafka Streams RocksDb iterators A. Sophie Blee-Goldman (Jira)
• [jira] [Created] (KAFKA-18041) Update key for global consumer in client instance ids Bill Bejeck (Jira)
• Re: [VOTE] KIP-655: Add deduplication processor in kafka-streams Lucas Brutschy
  • Re: [VOTE] KIP-655: Add deduplication processor in kafka-streams Bill Bejeck
  • Re: [VOTE] KIP-655: Add deduplication processor in kafka-streams Matthias J. Sax
• [jira] [Created] (KAFKA-18042) Reject the produce request with lower producer epoch early. Calvin Liu (Jira)
• [jira] [Created] (KAFKA-18039) Test all versions of quorum responses in RequestResponseTest Alyssa Huang (Jira)
• [jira] [Resolved] (KAFKA-16176) Flaky test: testSendToPartitionWithFollowerShutdownShouldNotTimeout – kafka.api.PlaintextProducerSendTest Kirk True (Jira)
• [jira] [Created] (KAFKA-18040) PlaintextProducerSendTest.testSendToPartitionWithFollowerShutdownShouldNotTimeout fails with CONSUMER group protocol Kirk True (Jira)
• [jira] [Resolved] (KAFKA-17733) Protocol upgrade should allow empty member assignment in group conversion David Jacot (Jira)
• [jira] [Resolved] (KAFKA-16460) New consumer times out consuming records in multiple consumer_test.py system tests Kirk True (Jira)
• [PR] MINOR: Fix the leak "unknown" group.coordinator.rebalance.protocols on document [kafka-site] via GitHub
  • Re: [PR] MINOR: Fix the leak "unknown" group.coordinator.rebalance.protocols on document [kafka-site] via GitHub
  • Re: [PR] MINOR: Fix the leak "unknown" group.coordinator.rebalance.protocols on document [kafka-site] via GitHub
• [jira] [Created] (KAFKA-18038) Flaky StreamThreadTest shouldLogAndRecordSkippedRecordsForInvalidTimestamps Lianet Magrans (Jira)
• Jenkins build is unstable: Kafka » Kafka Branch Builder » 3.8 #110 Apache Jenkins Server
  • Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.8 #111 Apache Jenkins Server
• [jira] [Resolved] (KAFKA-17850) Stop leaking internal exception to StreamsUncaughtExceptionHandler Bruno Cadonna (Jira)
• [PR] MINOR: document how to deal with advisories for dependencies [kafka-site] via GitHub
• [jira] [Created] (KAFKA-18037) Remove deprecated methods from EmbeddedConnect and EmbeddedConnectCluster Chia-Ping Tsai (Jira)
• [PR] MINOR: Fix 3.7.1 is a fixed version for CVE-2024-31141 [kafka-site] via GitHub
  • Re: [PR] MINOR: Fix 3.7.1 is a fixed version for CVE-2024-31141 [kafka-site] via GitHub
• [jira] [Resolved] (KAFKA-17887) Handle response log result error in DelayedShareFetch Apoorv Mittal (Jira)
• [VOTE] KIP-1112: allow custom processor wrapping Sophie Blee-Goldman
  • Re: [VOTE] KIP-1112: allow custom processor wrapping Bill Bejeck
  • Re: [VOTE] KIP-1112: allow custom processor wrapping Lucas Brutschy
  • Re: [VOTE] KIP-1112: allow custom processor wrapping Guozhang Wang
  • Re: [VOTE] KIP-1112: allow custom processor wrapping Bruno Cadonna
  • Re: [VOTE] KIP-1112: allow custom processor wrapping Sophie Blee-Goldman
• [PR] Add CVE-2024-31141 to CVE list [kafka-site] via GitHub
  • Re: [PR] Add CVE-2024-31141 to CVE list [kafka-site] via GitHub
• [jira] [Created] (KAFKA-18031) Flaky PlaintextConsumerTest testCloseLeavesGroupOnInterrupt Lianet Magrans (Jira)
• [jira] [Resolved] (KAFKA-18008) Flaky testMultiConsumerSessionTimeoutOnStopPolling Lianet Magrans (Jira)
• [jira] [Created] (KAFKA-18036) TransactionsWithTieredStoreTest testReadCommittedConsumerShouldNotSeeUndecidedData is flaky David Arthur (Jira)
• [jira] [Created] (KAFKA-18035) TransactionsTest testBumpTransactionalEpochWithTV2Disabled failed on trunk David Arthur (Jira)
• [jira] [Created] (KAFKA-18034) CommitRequestManager should fail pending requests on fatal coordinator errors Lianet Magrans (Jira)
• [jira] [Created] (KAFKA-18033) ShareConsumerTest testAcknowledgementCommitCallbackInvalidRecordStateException is flaky David Arthur (Jira)
• [jira] [Resolved] (KAFKA-18016) Fix bugs in handling piggyback acknowledgements in ShareFetch Shivsundar R (Jira)
• [jira] [Created] (KAFKA-18032) ProducerFencedExceptions should wipe out the state store only for the tasks that are related to the failed transaction Eduwer Camacaro (Jira)
• [jira] [Resolved] (KAFKA-17561) Operator Metrics for Kafka Streams Bill Bejeck (Jira)
• [VOTE] KIP-1099: Extend kafka-consumer-groups command line tool to support new consumer group PoAn Yang
  • Re: [VOTE] KIP-1099: Extend kafka-consumer-groups command line tool to support new consumer group Chia-Ping Tsai
  • Re: [VOTE] KIP-1099: Extend kafka-consumer-groups command line tool to support new consumer group David Jacot

• Earlier messages
• Later messages