jira  

Messages by Thread

• • [jira] [Comment Edited] (KAFKA-20879) Consider to add a `SuspendReason` to `StateRestoreListener#onRestoreSuspended` Hrishi Baskaran (Jira)
  • [jira] [Comment Edited] (KAFKA-20879) Consider to add a `SuspendReason` to `StateRestoreListener#onRestoreSuspended` Hrishi Baskaran (Jira)
• [jira] [Commented] (KAFKA-20879) Consider to add a `SuspendReason` to `StateRestoreListener#onRestoreSuspended` Hrishi Baskaran (Jira)
  • [jira] [Commented] (KAFKA-20879) Consider to add a `SuspendReason` to `StateRestoreListener#onRestoreSuspended` Matthias J. Sax (Jira)
  • [jira] [Commented] (KAFKA-20879) Consider to add a `SuspendReason` to `StateRestoreListener#onRestoreSuspended` Hrishi Baskaran (Jira)
• [jira] [Commented] (KAFKA-20357) lastProducerEpoch fields never persisted to transaction log sanghyeok An (Jira)
• [jira] [Created] (KAFKA-21004) [CVE-2026-68497][jackson-databind] Jira
• [PR] KAFKA-20923: Introduce headerVersions into RPC schema definitions [kafka] via GitHub
• [jira] [Updated] (KAFKA-21004) [CVE-2026-68497][jackson-databind] Chia-Ping Tsai (Jira)
• [jira] [Assigned] (KAFKA-21007) Migrate some test cases from KafkaRequestHandlerTest to BrokerTopicMetricsTest dino2895 (Jira)
• [jira] [Created] (KAFKA-21006) Migrate AbstractApiVersionsRequestTest, SaslApiVersionsRequestTest, ApiVersionsRequestTest to server module Chia-Ping Tsai (Jira)
• [PR] KAFKA-1983: Remove redundant offset commits from EndToEndLatency [kafka] via GitHub
• [jira] [Created] (KAFKA-21007) Migrate some test cases from KafkaRequestHandlerTest to BrokerTopicMetricsTest Chia-Ping Tsai (Jira)
• [jira] [Assigned] (KAFKA-21006) Migrate AbstractApiVersionsRequestTest, SaslApiVersionsRequestTest, ApiVersionsRequestTest to server module Lucy Liu (Jira)
• [jira] [Assigned] (KAFKA-20879) Consider to add a `SuspendReason` to `StateRestoreListener#onRestoreSuspended` Hrishi Baskaran (Jira)
• [jira] [Assigned] (KAFKA-21002) Remove hamcrest from org.apache.kafka.streams package majialong (Jira)
• [jira] [Comment Edited] (KAFKA-1983) TestEndToEndLatency can be unreliable after hard kill Rishabh Saraswat (Jira)
• [jira] [Commented] (KAFKA-1983) TestEndToEndLatency can be unreliable after hard kill Rishabh Saraswat (Jira)
  • [jira] [Commented] (KAFKA-1983) TestEndToEndLatency can be unreliable after hard kill Chia-Ping Tsai (Jira)
  • [jira] [Commented] (KAFKA-1983) TestEndToEndLatency can be unreliable after hard kill Rishabh Saraswat (Jira)
• [jira] [Assigned] (KAFKA-1983) TestEndToEndLatency can be unreliable after hard kill Chia-Ping Tsai (Jira)
• [jira] [Updated] (KAFKA-20965) Remove hamcrest from org.apache.kafka.streams.state.internals.metrics package Chia-Ping Tsai (Jira)
• [PR] KAFKA-20665: Make the assignment refiner injectable [kafka] via GitHub
  • Re: [PR] KAFKA-20665: Make the assignment refiner injectable [kafka] via GitHub
  • Re: [PR] KAFKA-20665: Make the assignment refiner injectable [kafka] via GitHub
  • Re: [PR] KAFKA-20665: Make the assignment refiner injectable [kafka] via GitHub
• [jira] [Assigned] (KAFKA-21003) `testValidCreateTopicsRequests` should verify replica assignments of created topics Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-20949) Remove hamcrest from org.apache.kafka.streams.query package Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21005) Remove hamcrest from org.apache.kafka.streams.kstream.internals package majialong (Jira)
• [PR] KAFKA-21004: Bump jackson to 2.21.6 [kafka] via GitHub
  • Re: [PR] KAFKA-21004: Bump jackson to 2.21.6 [kafka] via GitHub
  • Re: [PR] KAFKA-21004: Bump jackson to 2.21.6 [kafka] via GitHub
• [PR] MINOR: replace Collections.singleton() with Set.of() [kafka] via GitHub
  • Re: [PR] MINOR: replace Collections.singleton() with Set.of() [kafka] via GitHub
  • Re: [PR] MINOR: replace Collections.singleton() with Set.of() [kafka] via GitHub
• [jira] [Resolved] (KAFKA-20785) Unexpected InvalidTxnStateException on EndTxn when commit races with transaction timeout Justine Olshan (Jira)
• [PR] MINOR: add missing java.util.Collections import [kafka] via GitHub
  • Re: [PR] MINOR: add missing java.util.Collections import [kafka] via GitHub
  • Re: [PR] MINOR: add missing java.util.Collections import [kafka] via GitHub
  • Re: [PR] MINOR: add missing java.util.Collections import [kafka] via GitHub
  • Re: [PR] MINOR: add missing java.util.Collections import [kafka] via GitHub
  • Re: [PR] MINOR: add missing java.util.Collections import [kafka] via GitHub
  • Re: [PR] MINOR: add missing java.util.Collections import [kafka] via GitHub
  • Re: [PR] MINOR: add missing java.util.Collections import [kafka] via GitHub
  • Re: [PR] MINOR: add missing java.util.Collections import [kafka] via GitHub
  • Re: [PR] MINOR: add missing java.util.Collections import [kafka] via GitHub
• [jira] [Created] (KAFKA-21003) `testValidCreateTopicsRequests` should verify replica assignments of created topics Chia-Ping Tsai (Jira)
• [PR] KAFKA-18477 remove usage of OffsetForLeaderEpochRequest in AbstractFetcherThread (WIP) [kafka] via GitHub
• Re: [PR] KAFKA-18477 remove usage of OffsetForLeaderEpochRequest in AbstractFetcherThread (1/N) [kafka] via GitHub
• Re: [PR] KAFKA-20292 [6/N]: Add TargetAssignmentRecordsBuilder [kafka] via GitHub
• [jira] [Comment Edited] (KAFKA-20416) RocksDB loses entries during broker patches. Fabian Bell (Jira)
• [jira] [Created] (KAFKA-21002) Remove hamcrest from org.apache.kafka.streams package Chia-Ping Tsai (Jira)
• [PR] KAFKA-20979: Fix another gap in index metadata sync logic [kafka] via GitHub
  • Re: [PR] KAFKA-20979: Fix another gap in index metadata sync logic [kafka] via GitHub
  • Re: [PR] KAFKA-20979: Fix another gap in index metadata sync logic [kafka] via GitHub
  • Re: [PR] KAFKA-20979: Fix another gap in index metadata sync logic [kafka] via GitHub
  • Re: [PR] KAFKA-20979: Fix another gap in index metadata sync logic [kafka] via GitHub
  • Re: [PR] KAFKA-20979: Fix another gap in index metadata sync logic [kafka] via GitHub
  • Re: [PR] KAFKA-20979: Fix another gap in index metadata sync logic [kafka] via GitHub
  • Re: [PR] KAFKA-20979: Fix another gap in index metadata sync logic [kafka] via GitHub
  • Re: [PR] KAFKA-20979: Fix another gap in index metadata sync logic [kafka] via GitHub
  • Re: [PR] KAFKA-20979: Fix another gap in index metadata sync logic [kafka] via GitHub
  • Re: [PR] KAFKA-20979: Fix another gap in index metadata sync logic [kafka] via GitHub
  • Re: [PR] KAFKA-20979: Fix another gap in index metadata sync logic [kafka] via GitHub
  • Re: [PR] KAFKA-20979: Fix another gap in index metadata sync logic [kafka] via GitHub
  • Re: [PR] KAFKA-20979: Fix another gap in index metadata sync logic [kafka] via GitHub
• [jira] [Resolved] (KAFKA-20976) Make KRaft max partitions per request limit a config Andrew Grant (Jira)
• [PR] KAFKA-19672: Fix aggregate statistics parsing in producer performance… [kafka] via GitHub
• [PR] KAFKA-21001: Keep warm-up tasks sticky in the streams sticky assignor [kafka] via GitHub
  • Re: [PR] KAFKA-21001: Keep warm-up tasks sticky in the streams sticky assignor [kafka] via GitHub
  • Re: [PR] KAFKA-21001: Keep warm-up tasks sticky in the streams sticky assignor [kafka] via GitHub
• [jira] [Assigned] (KAFKA-21001) Sticky assignor ("streams" protocol) ignores warm-up tasks for stickiness Matthias J. Sax (Jira)
• [jira] [Created] (KAFKA-21001) Sticky assignor ("streams" protocol) ignores warm-up tasks for stickiness Matthias J. Sax (Jira)
• Re: [PR] KAFKA-18996 Expose addReadOnlyStateStore in DSL (StreamsBuilder) [kafka] via GitHub
  • Re: [PR] KAFKA-18996 Expose addReadOnlyStateStore in DSL (StreamsBuilder) [kafka] via GitHub
• Re: [PR] KAFKA-1792: change behavior of --generate to produce assignment config with fair replica distribution and minimal number of reassignments [kafka] via GitHub
  • Re: [PR] KAFKA-1792: change behavior of --generate to produce assignment config with fair replica distribution and minimal number of reassignments [kafka] via GitHub
• [jira] [Comment Edited] (KAFKA-10472) Consider migrating Topology methods to the Builder pattern Hrishi Baskaran (Jira)
  • [jira] [Comment Edited] (KAFKA-10472) Consider migrating Topology methods to the Builder pattern Hrishi Baskaran (Jira)
  • [jira] [Comment Edited] (KAFKA-10472) Consider migrating Topology methods to the Builder pattern Hrishi Baskaran (Jira)
  • [jira] [Comment Edited] (KAFKA-10472) Consider migrating Topology methods to the Builder pattern Hrishi Baskaran (Jira)
• [jira] [Commented] (KAFKA-10472) Consider migrating Topology methods to the Builder pattern Hrishi Baskaran (Jira)
  • [jira] [Commented] (KAFKA-10472) Consider migrating Topology methods to the Builder pattern Matthias J. Sax (Jira)
• [jira] [Assigned] (KAFKA-10472) Consider migrating Topology methods to the Builder pattern Hrishi Baskaran (Jira)
• [PR] MINOR: follow-up Replace Collections factory methods with Java 11+ equivalents in streams [kafka] via GitHub
  • Re: [PR] MINOR: follow-up Replace Collections factory methods with Java 11+ equivalents in streams [kafka] via GitHub
  • Re: [PR] MINOR: follow-up Replace Collections factory methods with Java 11+ equivalents in streams [kafka] via GitHub
  • Re: [PR] MINOR: follow-up Replace Collections factory methods with Java 11+ equivalents in streams [kafka] via GitHub
  • Re: [PR] MINOR: follow-up Replace Collections factory methods with Java 11+ equivalents in streams [kafka] via GitHub
  • Re: [PR] MINOR: follow-up Replace Collections factory methods with Java 11+ equivalents in streams [kafka] via GitHub
  • Re: [PR] MINOR: follow-up Replace Collections factory methods with Java 11+ equivalents in streams [kafka] via GitHub
  • Re: [PR] MINOR: follow-up Replace Collections factory methods with Java 11+ equivalents in streams [kafka] via GitHub
  • Re: [PR] MINOR: follow-up Replace Collections factory methods with Java 11+ equivalents in streams [kafka] via GitHub
  • Re: [PR] MINOR: follow-up Replace Collections factory methods with Java 11+ equivalents in streams [kafka] via GitHub
  • Re: [PR] MINOR: follow-up Replace Collections factory methods with Java 11+ equivalents in streams [kafka] via GitHub
• [jira] [Updated] (KAFKA-20995) KIP-1371: Formalize Consumer Reactor Cross-Manager Coordination and Publication Eric Chang (Jira)
• [jira] [Comment Edited] (KAFKA-20230) Allow globalTable to provide an optional KeyValueMapper to materialize an alternative K,V Hrishi Baskaran (Jira)
  • [jira] [Comment Edited] (KAFKA-20230) Allow globalTable to provide an optional KeyValueMapper to materialize an alternative K,V Hrishi Baskaran (Jira)
• [PR] KAFKA-20964: Do not echo salt or saltedPassword in ScramParser errors [kafka] via GitHub
• [jira] [Assigned] (KAFKA-20964) ScramParser flagged by security scanner Shantanu (Jira)
• [jira] [Commented] (KAFKA-20964) ScramParser flagged by security scanner Shantanu (Jira)
  • [jira] [Commented] (KAFKA-20964) ScramParser flagged by security scanner Shantanu (Jira)
• [jira] [Assigned] (KAFKA-20913) KafkaRaftClient#appendBatch reads a recycled batch buffer in its async commit callback, producing an incorrect appendTimestamp for committed batches Shantanu (Jira)
• [PR] KAFKA-20913: Snapshot CompletedBatch appendTimestamp before buffer reuse [kafka] via GitHub
• [jira] [Commented] (KAFKA-20913) KafkaRaftClient#appendBatch reads a recycled batch buffer in its async commit callback, producing an incorrect appendTimestamp for committed batches Shantanu (Jira)
  • [jira] [Commented] (KAFKA-20913) KafkaRaftClient#appendBatch reads a recycled batch buffer in its async commit callback, producing an incorrect appendTimestamp for committed batches Shantanu (Jira)
• Re: [PR] Add KafkaTopicCalculator feature [kafka] via GitHub
  • Re: [PR] Add KafkaTopicCalculator feature [kafka] via GitHub
• Re: [PR] Feature/grade [kafka] via GitHub
  • Re: [PR] Feature/grade [kafka] via GitHub
• Re: [PR] KAFKA-19738: Add unit tests for OffsetsRequestManager ListOffsets request building [kafka] via GitHub
  • Re: [PR] KAFKA-19738: Add unit tests for OffsetsRequestManager ListOffsets request building [kafka] via GitHub
  • Re: [PR] KAFKA-19738: Add unit tests for OffsetsRequestManager ListOffsets request building [kafka] via GitHub
• [PR] Added a validation to ensure that connection doesn't get dropped if the message size is larger than the socket request max size [kafka] via GitHub
  • Re: [PR] MINOR: Validation to check socket.request.max.bytes >= message.max.bytes [kafka] via GitHub
  • Re: [PR] MINOR: Validation to check socket.request.max.bytes >= message.max.bytes [kafka] via GitHub
• [PR] KAFKA-19895: Retry log cleaning after topic config updates [kafka] via GitHub
  • Re: [PR] KAFKA-19895: Retry log cleaning after topic config updates [kafka] via GitHub
• [jira] [Assigned] (KAFKA-19028) AlterConfigPolicy with OpType.DELETE : inconsistent behavior between TOPIC and BROKER resource Arnab Nandy (Jira)
• [PR] KAFKA-19028: Make incremental config deletion consistent for policies [kafka] via GitHub
  • Re: [PR] KAFKA-19028: Make incremental config deletion consistent for policies [kafka] via GitHub
• [PR] KAFKA-20990: Remove hamcrest from streams integration utils [kafka] via GitHub
  • Re: [PR] KAFKA-20990: Remove hamcrest from streams integration utils [kafka] via GitHub
  • Re: [PR] KAFKA-20990: Remove hamcrest from streams integration utils [kafka] via GitHub
  • Re: [PR] KAFKA-20990: Remove hamcrest from streams integration utils [kafka] via GitHub
  • Re: [PR] KAFKA-20990: Remove hamcrest from streams integration utils [kafka] via GitHub
  • Re: [PR] KAFKA-20990: Remove hamcrest from streams integration utils [kafka] via GitHub
  • Re: [PR] KAFKA-20990: Remove hamcrest from streams integration utils [kafka] via GitHub
  • Re: [PR] KAFKA-20990: Remove hamcrest from streams integration utils [kafka] via GitHub
  • Re: [PR] KAFKA-20990: Remove hamcrest from streams integration utils [kafka] via GitHub
  • Re: [PR] KAFKA-20990: Remove hamcrest from streams integration utils [kafka] via GitHub
• [PR] KAFKA-20952: Remove Hamcrest from kstream package tests [kafka] via GitHub
  • Re: [PR] KAFKA-20952: Remove Hamcrest from kstream package tests [kafka] via GitHub
  • Re: [PR] KAFKA-20952: Remove Hamcrest from kstream package tests [kafka] via GitHub
  • Re: [PR] KAFKA-20952: Remove Hamcrest from kstream package tests [kafka] via GitHub
  • Re: [PR] KAFKA-20952: Remove Hamcrest from kstream package tests [kafka] via GitHub
  • Re: [PR] KAFKA-20952: Remove Hamcrest from kstream package tests [kafka] via GitHub
  • Re: [PR] KAFKA-20952: Remove Hamcrest from kstream package tests [kafka] via GitHub
  • Re: [PR] KAFKA-20952: Remove Hamcrest from kstream package tests [kafka] via GitHub
  • Re: [PR] KAFKA-20952: Remove Hamcrest from kstream package tests [kafka] via GitHub
  • Re: [PR] KAFKA-20952: Remove Hamcrest from kstream package tests [kafka] via GitHub
• [PR] KAFKA-20953: Remove Hamcrest from Streams internals tests [kafka] via GitHub
  • Re: [PR] KAFKA-20953: Remove Hamcrest from Streams internals tests [kafka] via GitHub
  • Re: [PR] KAFKA-20953: Remove Hamcrest from Streams internals tests [kafka] via GitHub
  • Re: [PR] KAFKA-20953: Remove Hamcrest from Streams internals tests [kafka] via GitHub
  • Re: [PR] KAFKA-20953: Remove Hamcrest from Streams internals tests [kafka] via GitHub
  • Re: [PR] KAFKA-20953: Remove Hamcrest from Streams internals tests [kafka] via GitHub
  • Re: [PR] KAFKA-20953: Remove Hamcrest from Streams internals tests [kafka] via GitHub
  • Re: [PR] KAFKA-20953: Remove Hamcrest from Streams internals tests [kafka] via GitHub
  • Re: [PR] KAFKA-20953: Remove Hamcrest from Streams internals tests [kafka] via GitHub
• [jira] [Assigned] (KAFKA-20996) `InetAddress.getHostName` could take long to impact network thread Arnab Nandy (Jira)
• [jira] [Assigned] (KAFKA-4493) Connections to Kafka brokers should be validated md tanwir (Jira)
• [jira] [Comment Edited] (KAFKA-20887) IQ metadata is incomplete during "streams" protocol rebalances, causing incorrect IQ results md tanwir (Jira)
• [jira] [Commented] (KAFKA-21000) Potential data corruption on clean broker restart Tushar Saini (Jira)
• [PR] KAFKA-21000: Ensure FileRecords trim is fsynced when shutting down [kafka] via GitHub
  • Re: [PR] KAFKA-21000: Ensure FileRecords trim is fsynced when shutting down [kafka] via GitHub
  • Re: [PR] KAFKA-21000: Ensure FileRecords trim is fsynced when shutting down [kafka] via GitHub
  • Re: [PR] KAFKA-21000: Ensure FileRecords trim is fsynced when shutting down [kafka] via GitHub
  • Re: [PR] KAFKA-21000: Ensure FileRecords trim is fsynced when shutting down [kafka] via GitHub
• [PR] MINOR: Remove hamcrest from org.apache.kafka.streams.query package [kafka] via GitHub
  • Re: [PR] MINOR: Remove hamcrest from org.apache.kafka.streams.query package [kafka] via GitHub
  • Re: [PR] MINOR: Remove hamcrest from org.apache.kafka.streams.query package [kafka] via GitHub
  • Re: [PR] MINOR: Remove hamcrest from org.apache.kafka.streams.query package [kafka] via GitHub
• [PR] KAFKA-20036 Followup to preserve transaction metadata when a cleaned segment overflows [kafka] via GitHub
  • Re: [PR] KAFKA-20036 Followup to preserve transaction metadata when a cleaned segment overflows [kafka] via GitHub
  • Re: [PR] KAFKA-20036 Followup to preserve transaction metadata when a cleaned segment overflows [kafka] via GitHub
  • Re: [PR] KAFKA-20036 Followup to preserve transaction metadata when a cleaned segment overflows [kafka] via GitHub
  • Re: [PR] KAFKA-20036 Followup to preserve transaction metadata when a cleaned segment overflows [kafka] via GitHub
  • Re: [PR] KAFKA-20036 Followup to preserve transaction metadata when a cleaned segment overflows [kafka] via GitHub
• [jira] [Commented] (KAFKA-20996) `InetAddress.getHostName` could take long to impact network thread Jira
• [jira] [Assigned] (KAFKA-21000) Potential data corruption on clean broker restart Ken Huang (Jira)
• [jira] [Created] (KAFKA-20999) Add rack-aware standby task assignment Matthias J. Sax (Jira)
• [jira] [Created] (KAFKA-21000) Potential data corruption on clean broker restart Jun Rao (Jira)
• [jira] [Resolved] (KAFKA-20920) Document new group coordinator executor metrics Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-20998) Add HA task assignor Matthias J. Sax (Jira)
• [jira] [Assigned] (KAFKA-18972) Custom Processor supplied on addReadOnlyStateStore is not used when restoring state from topic Alieh Saeedi (Jira)
• [jira] [Updated] (KAFKA-20998) Add HA task assignor Gavin Wang (Jira)
• [jira] [Resolved] (KAFKA-20992) Remove hamcrest from org.apache.kafka.test package Hung-Yau Su (Jira)
• [jira] [Assigned] (KAFKA-20923) Introduce headerVersions into RPC schema definitions Alan Lau (Jira)
• [jira] [Assigned] (KAFKA-16867) Streams should run tag-based standby assignment based on rack ids Matthias J. Sax (Jira)
• [jira] [Assigned] (KAFKA-20998) Add HA task assignor Matthias J. Sax (Jira)
• [jira] [Assigned] (KAFKA-20999) Add rack-aware standby task assignment Matthias J. Sax (Jira)
• [jira] [Commented] (KAFKA-20997) Support running in FIPS environments Jira
• Re: [PR] KAFKA-18972: Use custom processor during read-only state store restoration [kafka] via GitHub
• [jira] [Created] (KAFKA-20997) Support running in FIPS environments Mickael Maison (Jira)
• [jira] [Updated] (KAFKA-20995) [Draft][KIP-1371] Introduce a Consumer Reactor for state management and event processing Eric Chang (Jira)
• [PR] KAFKA-19657: Updated RebalanceProtocolMigrationIntegrationTest [kafka] via GitHub
  • Re: [PR] KAFKA-19657: Updated RebalanceProtocolMigrationIntegrationTest [kafka] via GitHub
• [jira] [Resolved] (KAFKA-20882) Reduce build time: use lazy creation for Gradle tasks (i.e. use `tasks.register` instead of `task` or `tasks.create`) Jira
• [jira] [Comment Edited] (KAFKA-20882) Reduce build time: use lazy creation for Gradle tasks (i.e. use `tasks.register` instead of `task` or `tasks.create`) Jira
• [PR] MINOR: Fix race condition in verify_running [kafka] via GitHub
  • Re: [PR] MINOR: Fix race condition in verify_running [kafka] via GitHub
• [jira] [Assigned] (KAFKA-19657) Improve RebalanceProtocolMigrationIntegrationTest Naveen (Jira)
• [jira] [Resolved] (KAFKA-20979) Potential data loss caused by time index truncation Mickael Maison (Jira)
• [PR] KAFKA-14302: Advance restored offsets after changelog catch-up [kafka] via GitHub
  • Re: [PR] KAFKA-14302: Advance restored offsets after changelog catch-up [kafka] via GitHub
  • Re: [PR] KAFKA-14302: Advance restored offsets after changelog catch-up [kafka] via GitHub
  • Re: [PR] KAFKA-14302: Advance restored offsets after changelog catch-up [kafka] via GitHub
  • Re: [PR] KAFKA-14302: Advance restored offsets after changelog catch-up [kafka] via GitHub
• [jira] [Commented] (KAFKA-14302) Infinite probing rebalance if a changelog topic got emptied Ramu (Jira)

• Earlier messages
• Later messages