jira  

Messages by Thread

• [PR] MINOR: Remove DefaultExternalKRaftMetrics and use lambda instead [kafka] via GitHub
  • Re: [PR] MINOR: Remove DefaultExternalKRaftMetrics and use lambda instead [kafka] via GitHub
  • Re: [PR] MINOR: Remove DefaultExternalKRaftMetrics and use lambda instead [kafka] via GitHub
  • Re: [PR] MINOR: Remove DefaultExternalKRaftMetrics and use lambda instead [kafka] via GitHub
• [jira] [Resolved] (KAFKA-7405) Support for graceful handling of corrupted records in Kafka consumer Matthias J. Sax (Jira)
• [PR] MINOR: Fix thread safety issue in CoordinatorTimerImpl by using ConcurrentHashMap [kafka] via GitHub
  • Re: [PR] MINOR: Fix thread safety issue in CoordinatorTimerImpl by using ConcurrentHashMap [kafka] via GitHub
  • Re: [PR] MINOR: Fix thread safety issue in CoordinatorTimerImpl by using ConcurrentHashMap [kafka] via GitHub
• [jira] [Assigned] (KAFKA-20099) Clarify how "stream-time" works in the docs Alexander Salinas (Jira)
• [jira] [Created] (KAFKA-20104) Inquiry about migrating from ZooKeeper to KRaft Jianbin Chen (Jira)
• Re: [PR] KAFKA-19893: Reduce tiered storage redundancy with delayed upload (KIP-1241) [kafka] via GitHub
  • Re: [PR] KAFKA-19893: Reduce tiered storage redundancy with delayed upload (KIP-1241) [kafka] via GitHub
  • Re: [PR] KAFKA-19893: Reduce tiered storage redundancy with delayed upload (KIP-1241) [kafka] via GitHub
  • Re: [PR] KAFKA-19893: Reduce tiered storage redundancy with delayed upload (KIP-1241) [kafka] via GitHub
  • Re: [PR] KAFKA-19893: Reduce tiered storage redundancy with delayed upload (KIP-1241) [kafka] via GitHub
• [PR] KAFKA-20064: Made PartitionLeaderCache thread safe. (#21335) [kafka] via GitHub
  • Re: [PR] KAFKA-20064: Made PartitionLeaderCache thread safe. (#21335) [kafka] via GitHub
  • Re: [PR] KAFKA-20064: Made PartitionLeaderCache thread safe. (#21335) [kafka] via GitHub
  • Re: [PR] KAFKA-20064: Made PartitionLeaderCache thread safe. (#21335) [kafka] via GitHub
  • Re: [PR] KAFKA-20064: Made PartitionLeaderCache thread safe. (#21335) [kafka] via GitHub
  • Re: [PR] KAFKA-20064: Made PartitionLeaderCache thread safe. (#21335) [kafka] via GitHub
  • Re: [PR] KAFKA-20064: Made PartitionLeaderCache thread safe. (#21335) [kafka] via GitHub
  • Re: [PR] KAFKA-20064: Made PartitionLeaderCache thread safe. (#21335) [kafka] via GitHub
  • Re: [PR] KAFKA-20064: Made PartitionLeaderCache thread safe. (#21335) [kafka] via GitHub
  • Re: [PR] KAFKA-20064: Made PartitionLeaderCache thread safe. (#21335) [kafka] via GitHub
  • Re: [PR] KAFKA-20064: Made PartitionLeaderCache thread safe. (#21335) [kafka] via GitHub
  • Re: [PR] KAFKA-20064: Made PartitionLeaderCache thread safe. (#21335) [kafka] via GitHub
  • Re: [PR] KAFKA-20064: Made PartitionLeaderCache thread safe. (#21335) [kafka] via GitHub
  • [PR] KAFKA-20064: Made PartitionLeaderCache thread safe. (#21335) [kafka] via GitHub
  • Re: [PR] KAFKA-20064: Made PartitionLeaderCache thread safe. (#21335) [kafka] via GitHub
  • Re: [PR] KAFKA-20064: Made PartitionLeaderCache thread safe. (#21335) [kafka] via GitHub
• Re: [PR] KAFKA-19932: adding handling of OOM and avoiding wrapped as timeout [kafka] via GitHub
  • Re: [PR] KAFKA-19932: adding handling of OOM and avoiding wrapped as timeout [kafka] via GitHub
• [jira] [Commented] (KAFKA-20103) [Gradle] Properties should be assigned using the 'propName = value' syntax Jira
• [jira] [Assigned] (KAFKA-20103) [Gradle] Properties should be assigned using the 'propName = value' syntax Jira
• [PR] KAFKA-20103 properties value assignment syntax changed to 'propName = value' (in order to comply with future requirements announced for Gradle 10) [kafka] via GitHub
  • Re: [PR] KAFKA-20103 properties value assignment syntax changed to 'propName = value' (in order to comply with future requirements announced for Gradle 10) [kafka] via GitHub
  • Re: [PR] KAFKA-20103 properties value assignment syntax changed to 'propName = value' (in order to comply with future requirements announced for Gradle 10) [kafka] via GitHub
  • Re: [PR] KAFKA-20103 properties value assignment syntax changed to 'propName = value' (in order to comply with future requirements announced for Gradle 10) [kafka] via GitHub
• [jira] [Updated] (KAFKA-20103) [Gradle] Properties should be assigned using the 'propName = value' syntax Jira
  • [jira] [Updated] (KAFKA-20103) [Gradle] Properties should be assigned using the 'propName = value' syntax Jira
  • [jira] [Updated] (KAFKA-20103) [Gradle] Properties should be assigned using the 'propName = value' syntax Jira
  • [jira] [Updated] (KAFKA-20103) [Gradle] Properties should be assigned using the 'propName = value' syntax Jira
  • [jira] [Updated] (KAFKA-20103) [Gradle] Properties should be assigned using the 'propName = value' syntax Jira
  • [jira] [Updated] (KAFKA-20103) [Gradle] Properties should be assigned using the 'propName = value' syntax Jira
• [jira] [Created] (KAFKA-20103) [Gradle] Properties should be assigned using the 'propName = value' syntax Jira
• [jira] [Resolved] (KAFKA-18679) KafkaRaftMetrics metrics are exposing doubles instead of integers Jira
• [jira] [Updated] (KAFKA-18679) KafkaRaftMetrics metrics are exposing doubles instead of integers Jira
• [jira] [Created] (KAFKA-20102) Preparations for Gradle 10 Jira
• [PR] MINOR: Gradle version update: 9.2.1 -->> 9.3.1 [kafka] via GitHub
  • Re: [PR] MINOR: Gradle version update: 9.2.1 -->> 9.3.1 [kafka] via GitHub
  • Re: [PR] MINOR: Gradle version update: 9.2.1 -->> 9.3.1 [kafka] via GitHub
  • Re: [PR] MINOR: Gradle version update: 9.2.1 -->> 9.3.1 [kafka] via GitHub
• [jira] [Created] (KAFKA-20101) Support org.apache.kafka.sasl.oauthbearer.allowed.urls=* Romain Quinio (Jira)
• [PR] KAFKA-19877: Clarify ByteBuffer position and limit expectations for Deserializer [kafka] via GitHub
• [PR] [MINOR] Use more appropriate exception when validate builder parameters [kafka] via GitHub
  • Re: [PR] [MINOR] Use more appropriate exception when validate builder parameters [kafka] via GitHub
• [jira] [Updated] (KAFKA-19571) Race condition between log segment flush and file deletion causing log dir to go offline Mickael Maison (Jira)
  • [jira] [Updated] (KAFKA-19571) Race condition between log segment flush and file deletion causing log dir to go offline Mickael Maison (Jira)
  • [jira] [Updated] (KAFKA-19571) Race condition between log segment flush and file deletion causing log dir to go offline Mickael Maison (Jira)
• [PR] [MINOR] Fix DLQ headers [kafka] via GitHub
  • Re: [PR] MINOR: Correct exception naming and preserve original headers in DLQ [kafka] via GitHub
  • Re: [PR] MINOR: Correct exception naming and preserve original headers in DLQ [kafka] via GitHub
  • Re: [PR] MINOR: Correct exception naming and preserve original headers in DLQ [kafka] via GitHub
• [jira] [Assigned] (KAFKA-19571) Race condition between log segment flush and file deletion causing log dir to go offline Mickael Maison (Jira)
• [jira] [Resolved] (KAFKA-19571) Race condition between log segment flush and file deletion causing log dir to go offline Mickael Maison (Jira)
• [PR] KAFKA-17676: Fix NPE when starting tasks after config topic compaction [kafka] via GitHub
  • Re: [PR] KAFKA-17676: Fix NPE when starting tasks after config topic compaction [kafka] via GitHub
• [jira] [Commented] (KAFKA-20100) Fix broken links in Developer Guide ASF GitHub Bot (Jira)
• [jira] [Created] (KAFKA-20100) Fix broken links in Developer Guide Zhe Wang (Jira)
• [jira] [Updated] (KAFKA-20100) Fix broken links in Developer Guide Zhe Wang (Jira)
  • [jira] [Updated] (KAFKA-20100) Fix broken links in Developer Guide Zhe Wang (Jira)
• Re: [PR] KAFKA-19685: Add possibility of passing in revoked partitions in task precommit [kafka] via GitHub
  • Re: [PR] KAFKA-19685: Add possibility of passing in revoked partitions in task precommit [kafka] via GitHub
• Re: [PR] Revert "MINOR: Cleanup metadata module" [kafka] via GitHub
  • Re: [PR] Revert "MINOR: Cleanup metadata module" [kafka] via GitHub
• Re: [PR] KAFKA-19963: Add more information to doc to explain how to parallelize per topic with Kafka Streams [kafka] via GitHub
  • Re: [PR] KAFKA-19963: Add more information to doc to explain how to parallelize per topic with Kafka Streams [kafka] via GitHub
• Re: [PR] KAFKA-8504 [kafka] via GitHub
• [jira] [Assigned] (KAFKA-19979) Improve Kafka Streams config files Matthias J. Sax (Jira)
• [jira] [Commented] (KAFKA-17125) Streams Rebalance Protocol Matthias J. Sax (Jira)
  • [jira] [Commented] (KAFKA-17125) Streams Rebalance Protocol Colt McNealy (Jira)
• [jira] [Assigned] (KAFKA-17125) Streams Rebalance Protocol Matthias J. Sax (Jira)
• [PR] Kafka-16262: Add IQv2 to Kafka Streams documentation [kafka] via GitHub
  • Re: [PR] KAFKA-16262: Add IQv2 to Kafka Streams documentation [kafka] via GitHub
  • Re: [PR] KAFKA-16262: Add IQv2 to Kafka Streams documentation [kafka] via GitHub
  • Re: [PR] KAFKA-16262: Add IQv2 to Kafka Streams documentation [kafka] via GitHub
  • Re: [PR] KAFKA-16262: Add IQv2 to Kafka Streams documentation [kafka] via GitHub
  • Re: [PR] KAFKA-16262: Add IQv2 to Kafka Streams documentation [kafka] via GitHub
  • Re: [PR] KAFKA-16262: Add IQv2 to Kafka Streams documentation [kafka] via GitHub
  • Re: [PR] KAFKA-16262: Add IQv2 to Kafka Streams documentation [kafka] via GitHub
  • Re: [PR] KAFKA-16262: Add IQv2 to Kafka Streams documentation [kafka] via GitHub
  • Re: [PR] KAFKA-16262: Add IQv2 to Kafka Streams documentation [kafka] via GitHub
  • Re: [PR] KAFKA-16262: Add IQv2 to Kafka Streams documentation [kafka] via GitHub
• [jira] [Created] (KAFKA-20099) Clarify how "stream-time" works in the docs Matthias J. Sax (Jira)
• [jira] [Created] (KAFKA-20098) Create a command line tool for unclean-recovery Jonah Hooper (Jira)
• [jira] [Created] (KAFKA-20097) CREATE_TOPIC returns topic information if topic already exists Jonah Hooper (Jira)
• [jira] [Commented] (KAFKA-19430) Don't fail on RecordCorruptedException Jun Rao (Jira)
  • [jira] [Commented] (KAFKA-19430) Don't fail on RecordCorruptedException Uladzislau Blok (Jira)
  • [jira] [Commented] (KAFKA-19430) Don't fail on RecordCorruptedException Jun Rao (Jira)
• [PR] MINOR: update KIP-1071 docs for KafkaClientSupplier [kafka] via GitHub
  • Re: [PR] MINOR: update KIP-1071 docs for KafkaClientSupplier [kafka] via GitHub
  • Re: [PR] MINOR: update KIP-1071 docs for KafkaClientSupplier [kafka] via GitHub
  • Re: [PR] MINOR: update KIP-1071 docs for KafkaClientSupplier [kafka] via GitHub
  • Re: [PR] MINOR: update KIP-1071 docs for KafkaClientSupplier [kafka] via GitHub
  • Re: [PR] MINOR: update KIP-1071 docs for KafkaClientSupplier [kafka] via GitHub
  • Re: [PR] MINOR: update KIP-1071 docs for KafkaClientSupplier [kafka] via GitHub
• Re: [PR] KAFKA-16505: Adding dead letter queue in Kafka Streams [kafka] via GitHub
  • Re: [PR] KAFKA-16505: Adding dead letter queue in Kafka Streams [kafka] via GitHub
  • Re: [PR] KAFKA-16505: Adding dead letter queue in Kafka Streams [kafka] via GitHub
  • Re: [PR] KAFKA-16505: Adding dead letter queue in Kafka Streams [kafka] via GitHub
• [jira] [Resolved] (KAFKA-20085) Let's replace this verbose instruction with a custom Gradle task Chia-Ping Tsai (Jira)
• [jira] [Updated] (KAFKA-20064) A race condition in admin client can lead to the result future never being completed Nikita Shupletsov (Jira)
  • [jira] [Updated] (KAFKA-20064) A race condition in admin client can lead to the result future never being completed Chia-Ping Tsai (Jira)
• [jira] [Updated] (KAFKA-19943) Stale values in State Store after tombstone was compacted Uladzislau Blok (Jira)
• [jira] [Resolved] (KAFKA-20091) Fix inconsistency in time-based retention checks between remote and local segment deletion logic. Kamal Chandraprakash (Jira)
• Re: [PR] MINOR: improve error message on TLS certificate validation failure [kafka] via GitHub
  • Re: [PR] MINOR: improve error message on TLS certificate validation failure [kafka] via GitHub
• Re: [PR] KAFKA-19122: updateClusterMetadata receives multiples PartitionInfo [kafka] via GitHub
• Re: [PR] KAFKA-18754: Allow `PlainSaslServer` to pass client info through the negotiated properties. [kafka] via GitHub
  • Re: [PR] KAFKA-18754: Allow `PlainSaslServer` to pass client info through the negotiated properties. [kafka] via GitHub
• Re: [PR] KAFKA-1194: changes needed to run on Windows [kafka] via GitHub
  • Re: [PR] KAFKA-1194: changes needed to run on Windows [kafka] via GitHub
• [jira] [Created] (KAFKA-20096) RocksDB compatibility not documented Matthias J. Sax (Jira)
• [PR] KAFKA-19960: Close pending tasks on shutdown. [kafka] via GitHub
  • Re: [PR] KAFKA-19960: Close pending tasks on shutdown. [kafka] via GitHub
  • Re: [PR] KAFKA-19960: Close pending tasks on shutdown. [kafka] via GitHub
  • Re: [PR] KAFKA-19960: Close pending tasks on shutdown. [kafka] via GitHub
  • Re: [PR] KAFKA-19960: Close pending tasks on shutdown. [kafka] via GitHub
  • Re: [PR] KAFKA-19960: Close pending tasks on shutdown. [kafka] via GitHub
  • Re: [PR] KAFKA-19960: Close pending tasks on shutdown. [kafka] via GitHub
  • Re: [PR] KAFKA-19960: Close pending tasks on shutdown. [kafka] via GitHub
  • Re: [PR] KAFKA-19960: Close pending tasks on shutdown. [kafka] via GitHub
  • Re: [PR] KAFKA-19960: Close pending tasks on shutdown. [kafka] via GitHub
  • Re: [PR] KAFKA-19960: Close pending tasks on shutdown. [kafka] via GitHub
  • Re: [PR] KAFKA-19960: Close pending tasks on shutdown. [kafka] via GitHub
  • Re: [PR] KAFKA-19960: Close pending tasks on shutdown. [kafka] via GitHub
  • Re: [PR] KAFKA-19960: Close pending tasks on shutdown. [kafka] via GitHub
  • Re: [PR] KAFKA-19960: Close pending tasks on shutdown. [kafka] via GitHub
  • Re: [PR] KAFKA-19960: Close pending tasks on shutdown. [kafka] via GitHub
  • Re: [PR] KAFKA-19960: Close pending tasks on shutdown. [kafka] via GitHub
  • Re: [PR] KAFKA-19960: Close pending tasks on shutdown. [kafka] via GitHub
  • Re: [PR] KAFKA-19960: Close pending tasks on shutdown. [kafka] via GitHub
  • Re: [PR] KAFKA-19960: Close pending tasks on shutdown. [kafka] via GitHub
  • Re: [PR] KAFKA-19960: Close pending tasks on shutdown. [kafka] via GitHub
  • Re: [PR] KAFKA-19960: Close pending tasks on shutdown. [kafka] via GitHub
  • Re: [PR] KAFKA-19960: Close pending tasks on shutdown. [kafka] via GitHub
  • Re: [PR] KAFKA-19960: Close pending tasks on shutdown. [kafka] via GitHub
  • Re: [PR] KAFKA-19960: Close pending tasks on shutdown. [kafka] via GitHub
  • Re: [PR] KAFKA-19960: Close pending tasks on shutdown. [kafka] via GitHub
  • Re: [PR] KAFKA-19960: Close pending tasks on shutdown. [kafka] via GitHub
• Re: [PR] KAFKA-19964: API Versions Response returns minimum metadata version for finalized level when no quorum exists [kafka] via GitHub
  • Re: [PR] KAFKA-19964: API Versions Response returns minimum metadata version for finalized level when no quorum exists [kafka] via GitHub
  • Re: [PR] KAFKA-19964: API Versions Response returns minimum metadata version for finalized level when no quorum exists [kafka] via GitHub
• [jira] [Updated] (KAFKA-18193) Refactor Kafka Streams CloseOptions to Fluent API Style Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-20083) Move BrokerLifecycleManager to server module Mickael Maison (Jira)
• Re: [PR] MINOR: Fix `leader` param description in TopicPartitionInfo constructor [kafka] via GitHub
  • Re: [PR] MINOR: Fix `leader` param description in TopicPartitionInfo constructor [kafka] via GitHub
• [jira] [Created] (KAFKA-20095) Unnecessary triggers to delayed share fetch purgatory when no data fetched Abhinav Dixit (Jira)
• [jira] [Resolved] (KAFKA-20093) KAFKA_URL is baked in as an environment variable causing faulty server.properties Christo Lolov (Jira)
• [jira] [Commented] (KAFKA-16936) Upgrade slf4j to 2.0.9 and integrate "-Dslf4j.provider" to kafka script Konrad Windszus (Jira)
  • [jira] [Commented] (KAFKA-16936) Upgrade slf4j to 2.0.9 and integrate "-Dslf4j.provider" to kafka script Chia-Ping Tsai (Jira)
  • [jira] [Commented] (KAFKA-16936) Upgrade slf4j to 2.0.9 and integrate "-Dslf4j.provider" to kafka script Konrad Windszus (Jira)
  • [jira] [Commented] (KAFKA-16936) Upgrade slf4j to 2.0.9 and integrate "-Dslf4j.provider" to kafka script Julian Reschke (Jira)
• Re: [PR] KAFKA-19952: When remote storage keep outage status. the local segment never get deleted [kafka] via GitHub
  • Re: [PR] KAFKA-19952: When remote storage keep outage status. the local segment never get deleted [kafka] via GitHub
  • Re: [PR] KAFKA-19952: When remote storage keep outage status. the local segment never get deleted [kafka] via GitHub
• [PR] [MINOR] Remove debug print within testFileDoesNotExist [kafka] via GitHub
  • Re: [PR] MINOR: Remove debug print within testFileDoesNotExist [kafka] via GitHub
• Re: [PR] [WIP] KIP-891: Multiversioning in Kafka Connect - Connector Multiversion Integration Test [kafka] via GitHub
  • Re: [PR] [WIP] KIP-891: Multiversioning in Kafka Connect - Connector Multiversion Integration Test [kafka] via GitHub
• Re: [PR] KAFKA-19415 Shuffle the order of readPartitionInfo when fetching data. [kafka] via GitHub
• Re: [PR] MINOR:Extract public code [kafka] via GitHub
  • Re: [PR] MINOR:Extract public code [kafka] via GitHub
• [PR] MINOR: Remove onTopicsDeleted from ShareCoordinator [kafka] via GitHub
  • Re: [PR] MINOR: Remove onTopicsDeleted from ShareCoordinator [kafka] via GitHub
  • Re: [PR] MINOR: Remove onTopicsDeleted from ShareCoordinator [kafka] via GitHub
• [jira] [Assigned] (KAFKA-20094) Add sanity test coverage for default configuration (no environment variables) PoAn Yang (Jira)
• [jira] [Commented] (KAFKA-20093) KAFKA_URL is baked in as an environment variable causing faulty server.properties Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-20094) Add sanity test coverage for default configuration (no environment variables) Chia-Ping Tsai (Jira)
• [PR] MINOR: Do not set KAFKA_URL as ENV in Docker [kafka] via GitHub
  • Re: [PR] MINOR: Do not set KAFKA_URL as ENV in Docker [kafka] via GitHub
  • Re: [PR] MINOR: Do not set KAFKA_URL as ENV in Docker [kafka] via GitHub
  • Re: [PR] KAFKA-20093 Do not set KAFKA_URL as ENV in Docker [kafka] via GitHub
  • Re: [PR] KAFKA-20093 Do not set KAFKA_URL as ENV in Docker [kafka] via GitHub
  • Re: [PR] KAFKA-20093 Do not set KAFKA_URL as ENV in Docker [kafka] via GitHub
• [jira] [Assigned] (KAFKA-20093) KAFKA_URL is baked in as an environment variable causing faulty server.properties Christo Lolov (Jira)
• [jira] [Updated] (KAFKA-20093) KAFKA_URL is baked in as an environment variable causing faulty server.properties Christo Lolov (Jira)
  • [jira] [Updated] (KAFKA-20093) KAFKA_URL is baked in as an environment variable causing faulty server.properties Christo Lolov (Jira)
  • [jira] [Updated] (KAFKA-20093) KAFKA_URL is baked in as an environment variable causing faulty server.properties Christo Lolov (Jira)
  • [jira] [Updated] (KAFKA-20093) KAFKA_URL is baked in as an environment variable causing faulty server.properties Christo Lolov (Jira)
• [jira] [Created] (KAFKA-20093) KAFKA_URL is baked in as an environment variable causing faulty server.properties Christo Lolov (Jira)
• [jira] [Resolved] (KAFKA-20080) Add test case for duplicate ports with different hostnames in KafkaConfigTest Chia-Ping Tsai (Jira)
• [PR] KAFKA-19952: Don't upload to remote if the segment had already expired according to remote retention configure [kafka] via GitHub
  • Re: [PR] KAFKA-19952: Don't upload to remote if the segment had already expired according to remote retention configure [kafka] via GitHub
  • Re: [PR] KAFKA-19952: Don't upload to remote if the segment had already expired according to remote retention configure [kafka] via GitHub
  • Re: [PR] KAFKA-19952: Don't upload to remote if the segment had already expired according to remote retention configure [kafka] via GitHub
  • Re: [PR] KAFKA-19952: Don't upload to remote if the segment had already expired according to remote retention configure [kafka] via GitHub
  • Re: [PR] KAFKA-19952: Don't upload to remote if the segment had already expired according to remote retention configure [kafka] via GitHub
  • Re: [PR] KAFKA-19952: Don't upload to remote if the segment had already expired according to remote retention configure [kafka] via GitHub

• Earlier messages
• Later messages