dev  

Messages by Thread

• [jira] [Created] (KAFKA-19918) Group coordinator metrics should use monotonic clock Sean Quah (Jira)
• [jira] [Created] (KAFKA-19917) Move AbstractFetcherThread to server module Chih-Yuan Chien (Jira)
• [jira] [Created] (KAFKA-19916) Move ReplicaFetcherManager to server module Chih-Yuan Chien (Jira)
• [jira] [Created] (KAFKA-19915) Move HostedPartition, LogAppendResult and LogDeleteRecordsResult to server module Chih-Yuan Chien (Jira)
• [jira] [Created] (KAFKA-19914) Move AlterPartitionManager to server module Chih-Yuan Chien (Jira)
• [jira] [Created] (KAFKA-19913) Increase code coverage of VerifiableProperties class Pawandeep Singh (Jira)
• [jira] [Created] (KAFKA-19912) Investigate OOM error on builds due to leaded thread Kirk True (Jira)
• Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.9 #238 Apache Jenkins Server
• [DISCUSS] KIP-1240: Additional group configurations for share groups Andrew Schofield
• [jira] [Resolved] (KAFKA-19903) Add integration tests for handling throttled delivery records for Share Group Apoorv Mittal (Jira)
• [jira] [Resolved] (KAFKA-12392) Deprecate '--max-partition-memory-bytes' option in ConsoleProducer Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-19911) Flaky test ShareConsumerTest.testShareGroupMaxSizeConfigExceeded Francis Godinho (Jira)
• [jira] [Created] (KAFKA-19911) Flaky test ShareConsumerTest.testShareGroupMaxSizeConfigExceeded Francis Godinho (Jira)
• [jira] [Created] (KAFKA-19910) Support rack awareness in UniformHeterogeneousAssignmentBuilder PoAn Yang (Jira)
• [jira] [Created] (KAFKA-19908) Support rack awareness in RangeAssignor#assignHeterogeneousGroup PoAn Yang (Jira)
• [jira] [Created] (KAFKA-19909) Support rack awareness in UniformHomogeneousAssignmentBuilder PoAn Yang (Jira)
• [jira] [Created] (KAFKA-19907) Support rack awareness in RangeAssignor#assignHomogeneousGroup PoAn Yang (Jira)
• [PR] Monitoring table rendering, local JS references and site refresh [kafka-site] via GitHub
  • Re: [PR] Monitoring table rendering, local JS references and site refresh [kafka-site] via GitHub
  • Re: [PR] Monitoring table rendering, local JS references and site refresh [kafka-site] via GitHub
  • Re: [PR] Monitoring table rendering, local JS references and site refresh [kafka-site] via GitHub
• [jira] [Resolved] (KAFKA-19876) Replace the base image since openjdk image is deprecated Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-19831) Failures in the StateUpdater thread may lead to inability to shut down a stream thread Nikita Shupletsov (Jira)
• [jira] [Resolved] (KAFKA-2462) allow modifying soft limit for open files in Kafka startup script Gwen Shapira (Jira)
• [jira] [Created] (KAFKA-19906) NullPointerException from Streams Metrics Infra on Topology Startup Colt McNealy (Jira)
• Re: [DISCUSS] KIP-1035: StateStore managed changelog offsets Eduwer Camacaro
• New release branch 4.2 Christo Lolov
• [jira] [Created] (KAFKA-19905) Tight reconnection loop during shutdown Federico Valeri (Jira)
• [jira] [Created] (KAFKA-19904) Add handling throttled records delivery for lower delivery limit Apoorv Mittal (Jira)
• [jira] [Created] (KAFKA-19903) Add integration tests for handling throttled delivery records for Share Group Apoorv Mittal (Jira)
• [jira] [Resolved] (KAFKA-17541) Improve handling of delivery count Apoorv Mittal (Jira)
• [jira] [Resolved] (KAFKA-15419) Flaky DescribeClusterRequestTest Mickael Maison (Jira)
• [jira] [Created] (KAFKA-19902) Consumer triggers OFFSET_OUT_OF_RANGE and resets to earliest when committed offset's epoch has been deleted RivenSun (Jira)
• [PR] rerun gh actions [kafka-site] via GitHub
  • Re: [PR] rerun gh actions [kafka-site] via GitHub
• [jira] [Resolved] (KAFKA-19778) Share Partition Lag Persistence and Retrieval Andrew Schofield (Jira)
• [jira] [Created] (KAFKA-19901) improve the error message when changing the configuration of dynamic voters Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-19860) Implement integration tests for share group lag Andrew Schofield (Jira)
• [jira] [Resolved] (KAFKA-18328) Support for Topic Ids in Offset Fetch/Commit APIs (KIP-848) David Jacot (Jira)
• [jira] [Resolved] (KAFKA-19715) Consider bumping 3rd party Github Actions Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-19186) Mark OffsetCommit and OffsetFetch APIs as stable David Jacot (Jira)
• [jira] [Resolved] (KAFKA-19757) Mark KIP-932 interfaces as stable for GA release Andrew Schofield (Jira)
• [jira] [Resolved] (KAFKA-19364) Production-ready documentation Andrew Schofield (Jira)
• Please approve workflow runs for a two Gradle-related GitHub PR's Dejan Stojadinović
• [jira] [Resolved] (KAFKA-17853) Console share consumer is not terminated immediately Andrew Schofield (Jira)
• [DISCUSS] KIP-1242: Detection and handling of misrouted connections Andrew Schofield
• [jira] [Created] (KAFKA-19900) Fix the documentation for remove controller Luke Chen (Jira)
• [jira] [Resolved] (KAFKA-19777) Generator | Fix order of arguments to assertEquals in unit tests Ksolves India Limited (Jira)
• [jira] [Resolved] (KAFKA-19898) OOM in Tls12SelectorTest#testGracefulClose Lianet Magrans (Jira)
• [jira] [Resolved] (KAFKA-19882) JMX tags applied to all client metrics, not just client state for KIP-1091 Bill Bejeck (Jira)
• [jira] [Resolved] (KAFKA-19446) TV2 late marker can violate EOS guarantees. Matthias J. Sax (Jira)
• [jira] [Created] (KAFKA-19899) Bumping group epoch when member regex subscription changes from non empty to empty Dongnuo Lyu (Jira)
• Feature Request: Native Support for Cross-Cutting Exception Handling in Kafka Streams Dave Cracauer
• [DISCUSS] KIP-1241: Reduce tiered storage redundancy with delayed upload jian fu
• [jira] [Resolved] (KAFKA-19896) Use MockTime::sleep instead of retrying in ShareConsumeRequestManagerTest. Andrew Schofield (Jira)
• [jira] [Created] (KAFKA-19898) OOM in Tls12SelectorTest#testGracefulClose Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-19897) Add support for Java 25 in 3.9 branch Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-19896) Use MockTime::sleep instead of retrying in ShareConsumeRequestManagerTest. Shivsundar R (Jira)
• [jira] [Created] (KAFKA-19895) __consumer_offsets Partitions Growing to TB Size and Not Cleaning Until Broker Restart zhangtongr (Jira)
• [jira] [Resolved] (KAFKA-15283) Client support for OffsetFetch and OffsetCommit with topic ID Lianet Magrans (Jira)
• [jira] [Created] (KAFKA-19894) Reintroduce SaslPlainSslEndToEndAuthorizationTest Gaurav Narula (Jira)
• [jira] [Resolved] (KAFKA-14056) Test reading of old messages formats in ZK-to-KRaft upgrade test PoAn Yang (Jira)
• [jira] [Resolved] (KAFKA-18265) Optimizing SharePartition locking to improve fetch speed Apoorv Mittal (Jira)
• [jira] [Resolved] (KAFKA-19742) Acquisition lock timeout renewal in share consumer explicit mode Andrew Schofield (Jira)
• [jira] [Resolved] (KAFKA-19892) Acq lock timeout field in share ack response Andrew Schofield (Jira)
• [jira] [Created] (KAFKA-19893) Reduce redundant storage in remote tier (configurable) fujian (Jira)
• [jira] [Resolved] (KAFKA-19410) Validate alignment of subscribed topics and assigned partitions in share consumer Andrew Schofield (Jira)
• [PR] Multiple home page and styling updates. Site refresh as of 11/17 [kafka-site] via GitHub
  • Re: [PR] Multiple home page and styling updates. Site refresh as of 11/17 [kafka-site] via GitHub
• [jira] [Resolved] (KAFKA-19801) Introduce deliveryCompleteCount in DescribeShareGroupStateOffsets Chirag Wadhwa (Jira)
• [jira] [Resolved] (KAFKA-19815) Implementation of ShareConsumer.acquisitionLockTimeoutMs() method Andrew Schofield (Jira)
• [PR] KAFKA-19751: Java 23 is not officially supported [kafka-site] via GitHub
  • Re: [PR] KAFKA-19751: Java 23 is not officially supported [kafka-site] via GitHub
  • Re: [PR] KAFKA-19751: Java 23 is not officially supported [kafka-site] via GitHub
  • Re: [PR] KAFKA-19751: Java 23 is not officially supported [kafka-site] via GitHub
  • Re: [PR] KAFKA-19751: Java 23 is not officially supported [kafka-site] via GitHub
  • Re: [PR] KAFKA-19751: Java 23 is not officially supported [kafka-site] via GitHub
  • Re: [PR] KAFKA-19751: Java 23 is not officially supported [kafka-site] via GitHub
  • Re: [PR] KAFKA-19751: Java 23 is not officially supported [kafka-site] via GitHub
  • Re: [PR] KAFKA-19751: Java 23 is not officially supported [kafka-site] via GitHub
  • Re: [PR] KAFKA-19751: Java 23 is not officially supported [kafka-site] via GitHub
  • Re: [PR] KAFKA-19751: Java 23 is not officially supported [kafka-site] via GitHub
  • Re: [PR] KAFKA-19751: Java 23 is not officially supported [kafka-site] via GitHub
  • Re: [PR] KAFKA-19751: Java 23 is not officially supported [kafka-site] via GitHub
  • Re: [PR] KAFKA-19751: Java 23 is not officially supported [kafka-site] via GitHub
  • Re: [PR] KAFKA-19751: Java 23 is not officially supported [kafka-site] via GitHub
  • Re: [PR] KAFKA-19751: Java 23 is not officially supported [kafka-site] via GitHub
  • Re: [PR] KAFKA-19751: Java 23 is not officially supported [kafka-site] via GitHub
  • Re: [PR] KAFKA-19751: Java 23 is not officially supported [kafka-site] via GitHub
  • Re: [PR] KAFKA-19751: Java 23 is not officially supported [kafka-site] via GitHub
  • Re: [PR] KAFKA-19751: Java 23 is not officially supported [kafka-site] via GitHub
  • Re: [PR] KAFKA-19751: Java 23 is not officially supported [kafka-site] via GitHub
  • Re: [PR] KAFKA-19751: Java 23 is not officially supported [kafka-site] via GitHub
  • Re: [PR] KAFKA-19751: Java 23 is not officially supported [kafka-site] via GitHub
  • Re: [PR] KAFKA-19751: Java 23 is not officially supported [kafka-site] via GitHub
  • Re: [PR] KAFKA-19751: Java 23 is not officially supported [kafka-site] via GitHub
  • Re: [PR] KAFKA-19751: Java 23 is not officially supported [kafka-site] via GitHub
  • Re: [PR] KAFKA-19751: Java 23 is not officially supported [kafka-site] via GitHub
• [jira] [Created] (KAFKA-19892) Acq lock timeout field in share ack response Sushant Mahajan (Jira)
• [jira] [Created] (KAFKA-19891) AsyncKafkaConsumer logs "Unexpected exception" for timeouts during close Lucas Brutschy (Jira)
• Guidance regarding implementation of an Information Flow control IFC system for Kafka Adithya M S
• [jira] [Resolved] (KAFKA-19816) Resolve flaky test: org.apache.kafka.streams.integration.EosIntegrationTest.shouldNotViolateEosIfOneTaskFails Lucas Brutschy (Jira)
• Re: [VOTE]: KIP-1071: Streams Rebalance Protocol Lucas Brutschy
• [jira] [Resolved] (KAFKA-19800) Compute share partition lag in GroupCoordinatorService Chirag Wadhwa (Jira)
• [jira] [Resolved] (KAFKA-19751) Fix the "6.6 Java Version" for branch 3.9 PoAn Yang (Jira)
• [jira] [Created] (KAFKA-19890) Fix start/stop command failure after wmic removal in newer Windows. fujian (Jira)
• [jira] [Created] (KAFKA-19889) max.connections.per.ip.overrides does not apply overrides to all IPs for multi-IP hostnames Vadym Zhytkevych (Jira)
• [jira] [Resolved] (KAFKA-19720) Regex subscription should be empty for classic members joining mixed group David Jacot (Jira)
• [jira] [Resolved] (KAFKA-19449) Unexpected UNREVOKED_PARTITIONS to UNRELEASED_PARTITIONS transition in consumer member reconciliation David Jacot (Jira)
• [DISCUSS] Apache Kafka 3.9.2 release PoAn Yang
• [PR] KAFKA-19751: KAFKA-19751: add Java 21, 23 to 3.9 supported version [kafka-site] via GitHub
  • Re: [PR] KAFKA-19751: KAFKA-19751: add Java 21, 23 to 3.9 supported version [kafka-site] via GitHub
  • Re: [PR] KAFKA-19751: KAFKA-19751: add Java 21, 23 to 3.9 supported version [kafka-site] via GitHub
  • Re: [PR] KAFKA-19751: KAFKA-19751: add Java 21, 23 to 3.9 supported version [kafka-site] via GitHub
  • Re: [PR] KAFKA-19751: KAFKA-19751: add Java 21, 23 to 3.9 supported version [kafka-site] via GitHub
  • Re: [PR] KAFKA-19751: KAFKA-19751: add Java 21, 23 to 3.9 supported version [kafka-site] via GitHub
  • Re: [PR] KAFKA-19751: KAFKA-19751: add Java 21, 23 to 3.9 supported version [kafka-site] via GitHub
• Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.9 #235 Apache Jenkins Server
• [jira] [Resolved] (KAFKA-19840) Flaky test ShareConsumerTest. testShareGroupMaxSizeConfigExceeded Andrew Schofield (Jira)
• [jira] [Resolved] (KAFKA-19826) KIP-1224: Implement adaptive append.linger.ms for the group coordinator and share coordinator David Jacot (Jira)
• [jira] [Resolved] (KAFKA-19764) KIP-1224: Adaptive append.linger.ms for the group coordinator and share coordinator David Jacot (Jira)
• [jira] [Resolved] (KAFKA-19857) CoordinatorExecutorImpl.cancelAll always throws IllegalStateException when there are running tasks David Jacot (Jira)
• [jira] [Resolved] (KAFKA-19825) KIP-1224: Add batch-linger-time and batch-flush-time metrics David Jacot (Jira)
• [jira] [Reopened] (KAFKA-19737) Fix PluginUtils#pluginLocations warning log not being printed Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-18794) Flaky test: KafkaShareConsumerTest.testVerifyFetchAndCloseImplicit Shivsundar R (Jira)
• [jira] [Resolved] (KAFKA-19767) Improve handling of long processing times Andrew Schofield (Jira)
• [jira] [Resolved] (KAFKA-19737) Fix PluginUtils#pluginLocations warning log not being printed majialong (Jira)
  • [jira] [Resolved] (KAFKA-19737) Fix PluginUtils#pluginLocations warning log not being printed Chia-Ping Tsai (Jira)
• [PR] MINOR: remove 4.1.0 from supported released (after 4.1.1) [kafka-site] via GitHub
  • Re: [PR] MINOR: remove 4.1.0 from supported released (after 4.1.1) [kafka-site] via GitHub
  • Re: [PR] MINOR: remove 4.1.0 from supported released (after 4.1.1) [kafka-site] via GitHub
  • Re: [PR] MINOR: remove 4.1.0 from supported released (after 4.1.1) [kafka-site] via GitHub
• [jira] [Created] (KAFKA-19888) Coordinator histogram negative values causing persistent write timeouts and consumer instability in Kafka 4.1.0 Eliel Gomes (Jira)
• [jira] [Resolved] (KAFKA-19869) Mark RPCs as stable Lucas Brutschy (Jira)
• [ANNOUNCE] Apache Kafka 4.1.1 Lianet Magrans
  • Re: [ANNOUNCE] Apache Kafka 4.1.1 Chia-Ping Tsai
  • Re: [ANNOUNCE] Apache Kafka 4.1.1 Apoorv Mittal
• [jira] [Resolved] (KAFKA-19561) Request Timeout During SASL Reauthentication Due to Missed OP_WRITE interest set Manikumar (Jira)
• [PR] Update top navbar to be more closer to the current look and feel [kafka-site] via GitHub
  • Re: [PR] Update top navbar to be more closer to the current look and feel [kafka-site] via GitHub
• Re: [DISCUSS] KIP-932: Queues for Kafka Chia-Ping Tsai
  • Re: [DISCUSS] KIP-932: Queues for Kafka Andrew Schofield
• [PR] MINOR: blog post and download links for 4.1.1 [kafka-site] via GitHub
  • Re: [PR] MINOR: blog post and download links for 4.1.1 [kafka-site] via GitHub
  • Re: [PR] MINOR: blog post and download links for 4.1.1 [kafka-site] via GitHub
  • Re: [PR] MINOR: blog post and download links for 4.1.1 [kafka-site] via GitHub
  • Re: [PR] MINOR: blog post and download links for 4.1.1 [kafka-site] via GitHub
• [jira] [Created] (KAFKA-19887) Add separate option for topic regex pattern matching in tools Lan Ding (Jira)
• [jira] [Created] (KAFKA-19886) Togdor | Fix order of arguments in assertEquals() in unit tests Ksolves India Limited (Jira)
• [PR] Home page refresh [kafka-site] via GitHub
  • Re: [PR] Home page refresh [kafka-site] via GitHub
• [DISCUSS] KIP-1238: Multipartition for TopologyTestDriver in Kafka Streams Sebastien Viale
• Re: [DISCUSS] KIP-853: KRaft Controller Membership Changes Luke Chen
  • Re: [DISCUSS] KIP-853: KRaft Controller Membership Changes Luke Chen
• [jira] [Resolved] (KAFKA-19842) Additional tests in ShareConsumerTest Sushant Mahajan (Jira)
• [jira] [Created] (KAFKA-19885) Explicity define either `execution` or `dry-run`when altering the offsets Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-15402) Performance regression on close consumer after upgrading to 3.5.0 Kirk True (Jira)
• [jira] [Created] (KAFKA-19884) Add tests to ensure Consumer.close() timeouts work as documented Kirk True (Jira)
• [jira] [Created] (KAFKA-19883) Support Hierarchical Transactional Acknowledgments for Share Groups Shekhar Prasad Rajak (Jira)
• [PR] MINOR: update javadoc for 4.1.1 [kafka-site] via GitHub
  • Re: [PR] MINOR: update javadoc for 4.1.1 [kafka-site] via GitHub
• [jira] [Created] (KAFKA-19882) JMX tags applied to all client metrics, not just client state for KIP-1091 Bill Bejeck (Jira)
• [jira] [Resolved] (KAFKA-14768) Add latency optimization guidance to KafkaProducer.send() Chia-Ping Tsai (Jira)
• [PR] MINOR: updates for 4.1.1 [kafka-site] via GitHub
  • Re: [PR] MINOR: updates for 4.1.1 [kafka-site] via GitHub
  • Re: [PR] MINOR: updates for 4.1.1 [kafka-site] via GitHub
  • Re: [PR] MINOR: updates for 4.1.1 [kafka-site] via GitHub
• [jira] [Created] (KAFKA-19881) Docker Image CVE Scanner workflow consistently failing Mickael Maison (Jira)
• Please approve workflow runs for Gradle Shadow plugin version upgrade PR Dejan Stojadinović
• [jira] [Created] (KAFKA-19880) First batch in producer epoch can be appended out-of-order even for idempotent producer Ivan Yurchenko (Jira)
• Q: validating interdependent configuration options. Claude Warren, Jr
  • Re:Q: validating interdependent configuration options. Hector Geraldino (BLOOMBERG/ 919 3RD A)
• [jira] [Created] (KAFKA-19879) How to keep compatibility when the configuration validator gets changed? Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-19878) Connect | Fix order of arguments in assertEquals Ksolves India Limited (Jira)
• [jira] [Resolved] (KAFKA-19845) Share consumer changes to support renew ack. Andrew Schofield (Jira)
• Request for review Stig Rohde Døssing
  • Re: Request for review Chia-Ping Tsai
• [jira] [Resolved] (KAFKA-19493) Incorrect rate metric with larger window size Apoorv Mittal (Jira)
• More advanced broker side consumer group management Levani Kokhreidze
  • Re: More advanced broker side consumer group management Andrew Mills
  • Re: More advanced broker side consumer group management Levani Kokhreidze
  • Re: More advanced broker side consumer group management David Jacot
  • Re: More advanced broker side consumer group management Levani Kokhreidze
  • Re: More advanced broker side consumer group management David Jacot
  • Re: More advanced broker side consumer group management Lucas Brutschy
• [DISCUSS] KIP-1236: Adjust quorum-related config lower bounds TaiJu Wu
  • re: [DISCUSS] KIP-1236: Adjust quorum-related config lower bounds Maroš Orsák
  • Re: [DISCUSS] KIP-1236: Adjust quorum-related config lower bounds TaiJu Wu
  • re: [DISCUSS] KIP-1236: Adjust quorum-related config lower bounds Maroš Orsák
• [DISCUSS] KIP-1237: Deprecate group.coordinator.rebalance.protocols config Ming-Yen Chung
  • Re: [DISCUSS] KIP-1237: Deprecate group.coordinator.rebalance.protocols config Matthias J. Sax
  • Re: [DISCUSS] KIP-1237: Deprecate group.coordinator.rebalance.protocols config Ming-Yen Chung
  • Re: [DISCUSS] KIP-1237: Deprecate group.coordinator.rebalance.protocols config Ming-Yen Chung
  • Re: [DISCUSS] KIP-1237: Deprecate group.coordinator.rebalance.protocols config Chia-Ping Tsai
  • Re: [DISCUSS] KIP-1237: Deprecate group.coordinator.rebalance.protocols config Ming-Yen Chung
• [jira] [Created] (KAFKA-19877) Clarify Deserializer contract around ByteBuffer position, limit Steven Schlansker (Jira)
• [PR] Rehaul of streams intro section [kafka-site] via GitHub
  • Re: [PR] Rehaul of streams intro section [kafka-site] via GitHub
• [jira] [Resolved] (KAFKA-19864) Handle TimeoutException from initializeIfNeeded() in StateUpdater Code Shashank (Jira)
• [jira] [Created] (KAFKA-19876) Replace the base image since openjdk image is deprecated Chia-Ping Tsai (Jira)

• Earlier messages