Messages by Date
-
2026/05/17
[jira] [Resolved] (KAFKA-20592) Fix several typos in Streams and upgrade documentation
Chia-Ping Tsai (Jira)
-
2026/05/17
Re: [PR] KAFKA-20592: Fix typos in Streams documentation [kafka]
via GitHub
-
2026/05/17
Re: [PR] MINOR: Rewrite FetchFromFollowerIntegrationTest from Scala to Java and move to server module [kafka]
via GitHub
-
2026/05/17
Re: [PR] MINOR: Simplify Tests Independent from Consumer in BaseProducerSendTest [kafka]
via GitHub
-
2026/05/17
Re: [PR] KAFKA-19620: Move AutoTopicCreationManager to server module [kafka]
via GitHub
-
2026/05/17
Re: [PR] MINOR: Update javadocs for GroupConfig and GroupConfigManager [kafka]
via GitHub
-
2026/05/17
Re: [PR] MINOR: Prevent this leak while DefaultStatePersister construction. [kafka]
via GitHub
-
2026/05/16
Re: [PR] KAFKA-20385 [1/N]: Add RebalanceConsumer interface and callback impl [kafka]
via GitHub
-
2026/05/16
Re: [PR] KAFKA-20150: Add Structurizr scaffolding for C4 Diagrams [kafka]
via GitHub
-
2026/05/16
Re: [PR] Return friendly prompt when no quota configs found [kafka]
via GitHub
-
2026/05/16
[PR] KAFKA-9479: Print describe --state header once for multiple groups [kafka]
via GitHub
-
2026/05/16
Re: [PR] MINOR: Add toString() to KafkaMetric for readable logging [kafka]
via GitHub
-
2026/05/16
Re: [PR] KAFKA-20169: Support static membership for Kafka Streams with the streams rebalance protocol (1/N) [kafka]
via GitHub
-
2026/05/16
Re: [PR] KAFKA-20430 Add configuration to control internal topic creation in Kafka Connect [kafka]
via GitHub
-
2026/05/16
Re: [PR] KAFKA-20539 Prevent Hot Data Loss on Partition Expansion for Latest Policy (WIP) [kafka]
via GitHub
-
2026/05/16
Re: [PR] KAFKA-20585 : Share Fetch latency metric incorrectly updated during ShareAcknowledgeResponse [kafka]
via GitHub
-
2026/05/16
[PR] KAFKA-20549: Change ownership of DLQ state manager. [kafka]
via GitHub
-
2026/05/16
Re: [PR] MINOR: Replace Collections factory methods with Java 11+ equivalents in clients [kafka]
via GitHub
-
2026/05/16
Re: [PR] MINOR: Prevent this leak while DefaultStatePersister construction. [kafka]
via GitHub
-
2026/05/16
Re: [PR] KAFKA-19790: Parse space-delimited OAuth scope claim strings [kafka]
via GitHub
-
2026/05/16
[jira] [Commented] (KAFKA-20560) Support non-blocking DeleteRecordsRequest
TaiJuWu (Jira)
-
2026/05/16
[jira] [Created] (KAFKA-20594) Kafka Streams issue
Aayush Gupta (Jira)
-
2026/05/16
[jira] [Updated] (KAFKA-19663) kafka-broker-api tool should support to get controller api version
TaiJuWu (Jira)
-
2026/05/15
[jira] [Updated] (KAFKA-20592) Fix several typos in Streams and upgrade documentation
Akhil Sabu (Jira)
-
2026/05/15
[jira] [Updated] (KAFKA-20592) Fix several typos in Streams and upgrade documentation
Akhil Sabu (Jira)
-
2026/05/15
[jira] [Assigned] (KAFKA-20592) Fix several typos in Streams and upgrade documentation
Sanskar Jhajharia (Jira)
-
2026/05/15
[PR] KAFKA-20592: Fix typos in Streams documentation [kafka]
via GitHub
-
2026/05/15
[jira] [Assigned] (KAFKA-20586) Flaky : LeaderElectionCommandTest > testPreferredReplicaElection [1] Type=Raft-Isolated, MetadataVersion=4.4-IV0
majialong (Jira)
-
2026/05/15
Re: [PR] KAFKA-20395: Support unregistering controllers [kafka]
via GitHub
-
2026/05/15
[jira] [Comment Edited] (KAFKA-19790) Parsing of the scope claim does not comply with RFC-8693
Yunseop Eom (Jira)
-
2026/05/15
[jira] [Comment Edited] (KAFKA-19790) Parsing of the scope claim does not comply with RFC-8693
Yunseop Eom (Jira)
-
2026/05/15
[jira] [Commented] (KAFKA-19790) Parsing of the scope claim does not comply with RFC-8693
Yunseop Eom (Jira)
-
2026/05/15
[PR] KAFKA-19790: Parse space-delimited OAuth scope claim strings [kafka]
via GitHub
-
2026/05/15
Re: [PR] MINOR: Prefer MetadataRecordSerde.INSTANCE over new instances [kafka]
via GitHub
-
2026/05/15
Re: [PR] KAFKA-17689 Change TieredStorageTestContext to use ClusterInstance [kafka]
via GitHub
-
2026/05/15
Re: [PR] KAFKA-17689 Change TieredStorageTestContext to use ClusterInstance [kafka]
via GitHub
-
2026/05/15
Re: [PR] KAFKA-17689 Change TieredStorageTestContext to use ClusterInstance [kafka]
via GitHub
-
2026/05/15
Re: [PR] MINOR: Prevent this leak while DefaultStatePersister construction. [kafka]
via GitHub
-
2026/05/15
Re: [PR] KAFKA-18389: Preserve votedKey when transitioning to leader state [kafka]
via GitHub
-
2026/05/15
Re: [PR] KAFKA-18389: Preserve votedKey when transitioning to leader state [kafka]
via GitHub
-
2026/05/15
Re: [PR] MINOR: Use NullNode instead of empty TextNode for missing request/response fields [kafka]
via GitHub
-
2026/05/15
[jira] [Updated] (KAFKA-18731) KStream-GlobalKTabel ValueJoinerWithKey passed incorrect key
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Updated] (KAFKA-18731) KStream-GlobalKTabel ValueJoinerWithKey passed incorrect key
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Updated] (KAFKA-18731) KStream-GlobalKTabel ValueJoinerWithKey passed incorrect key
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Updated] (KAFKA-20587) Flaky : KafkaStreamsTelemetryIntegrationTest > "shouldPushGlobalThreadMetricsToBroker(String, String).recordingLevel=INFO, groupProtocol=streams
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Updated] (KAFKA-20587) Flaky : KafkaStreamsTelemetryIntegrationTest > "shouldPushGlobalThreadMetricsToBroker(String, String).recordingLevel=INFO, groupProtocol=streams
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Resolved] (KAFKA-1669) Default rebalance retries and backoff should be higher
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Assigned] (KAFKA-1669) Default rebalance retries and backoff should be higher
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Commented] (KAFKA-1639) Support control messages in Kafka
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Assigned] (KAFKA-1659) Ability to cleanly abort the KafkaProducer
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Assigned] (KAFKA-1631) ReplicationFactor and under-replicated partitions incorrect during reassignment
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Resolved] (KAFKA-1623) kafka is sometimes slow to accept connections
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Resolved] (KAFKA-1626) Use Jekyll for website
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Assigned] (KAFKA-1626) Use Jekyll for website
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Resolved] (KAFKA-1591) Clean-up Unnecessary stack trace in error/warn logs
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Resolved] (KAFKA-1610) Local modifications to collections generated from mapValues will be lost
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Commented] (KAFKA-20593) Log a diagnostic warning at startup when Kafka Streams detects internal repartition topics
Jahnavi Patel (Jira)
-
2026/05/15
[jira] [Resolved] (KAFKA-1590) Binarize trace level request logging along with debug level text logging
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Resolved] (KAFKA-1566) Kafka environment configuration (kafka-env.sh)
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Assigned] (KAFKA-1579) End-to-End tool to measure performance and correctness test
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Resolved] (KAFKA-1543) Changing replication factor
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Resolved] (KAFKA-1534) transient unit test failure in testBasicPreferredReplicaElection
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Resolved] (KAFKA-1452) Killing last replica for partition doesn't change ISR/Leadership if replica is running controller
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Resolved] (KAFKA-1450) check invalid leader in a more robust way
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Resolved] (KAFKA-1352) Reduce logging on the server
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Resolved] (KAFKA-1351) String.format is very expensive in Scala
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Assigned] (KAFKA-1452) Killing last replica for partition doesn't change ISR/Leadership if replica is running controller
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Assigned] (KAFKA-1448) Filter-plugins for messages
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Assigned] (KAFKA-1352) Reduce logging on the server
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Assigned] (KAFKA-1313) Support adding replicas to existing topic partitions via kafka-topics tool without manually setting broker assignments
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Resolved] (KAFKA-1313) Support adding replicas to existing topic partitions via kafka-topics tool without manually setting broker assignments
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Updated] (KAFKA-20489) Add config to control state wipe behaviour
Bill Bejeck (Jira)
-
2026/05/15
[jira] [Updated] (KAFKA-20489) Add config to control state wipe behaviour
Bill Bejeck (Jira)
-
2026/05/15
[jira] [Resolved] (KAFKA-1300) Added WaitForReplaction admin tool.
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Updated] (KAFKA-20492) Factor out RocksDBStore iteration methods to DBAccessor
Bill Bejeck (Jira)
-
2026/05/15
[jira] [Resolved] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Updated] (KAFKA-20492) Factor out RocksDBStore iteration methods to DBAccessor
Bill Bejeck (Jira)
-
2026/05/15
[jira] [Resolved] (KAFKA-1206) allow Kafka to start from a resource negotiator system
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Resolved] (KAFKA-1299) Standardize configs across tools
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Resolved] (KAFKA-1122) Kafka can log giant log lines
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Resolved] (KAFKA-1088) Ability to create a shadow consumer group
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Resolved] (KAFKA-1101) Need better java api for embedding kafkaserver in a java container app
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Assigned] (KAFKA-1088) Ability to create a shadow consumer group
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Assigned] (KAFKA-1063) run log cleanup at startup
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Assigned] (KAFKA-740) Improve crash-safety of log segment swap
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Resolved] (KAFKA-1043) Time-consuming FetchRequest could block other request in the response queue
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Resolved] (KAFKA-1021) Write a tool to check replica lag for individual topic partitions
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Resolved] (KAFKA-1014) Junits and system tests for inbuilt offset management
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Assigned] (KAFKA-1021) Write a tool to check replica lag for individual topic partitions
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Assigned] (KAFKA-1014) Junits and system tests for inbuilt offset management
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Resolved] (KAFKA-859) support basic auth protection of mx4j console
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Resolved] (KAFKA-960) Upgrade Metrics to 3.x
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Resolved] (KAFKA-841) Merge the partition and replica state machines into a single unified state machine in the controller
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Resolved] (KAFKA-747) RequestChannel re-design
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Assigned] (KAFKA-841) Merge the partition and replica state machines into a single unified state machine in the controller
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Resolved] (KAFKA-740) Improve crash-safety of log segment swap
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Assigned] (KAFKA-747) RequestChannel re-design
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Assigned] (KAFKA-560) Garbage Collect obsolete topics
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Resolved] (KAFKA-566) Add last modified time to the TopicMetadataRequest
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Resolved] (KAFKA-560) Garbage Collect obsolete topics
Matthias J. Sax (Jira)
-
2026/05/15
[PR] [INFRA] Set up default rulesets for default and release branches [kafka]
via GitHub
-
2026/05/15
[PR] [INFRA] Set up default rulesets for default and release branches [kafka-merge-queue-sandbox]
via GitHub
-
2026/05/15
[jira] [Updated] (KAFKA-19731) Remove AppInfoParser deprecated metrics
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Updated] (KAFKA-19731) Remove AppInfoParser deprecated metrics
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Updated] (KAFKA-20573) KIP-1338: Structured MDC Context for Kafka Logging
Matthias J. Sax (Jira)
-
2026/05/15
Re: [PR] KAFKA-20489: Add enable.transactional.statestores [kafka]
via GitHub
-
2026/05/15
Re: [PR] KAFKA-20492: Prepare DBAccessor for txn support [kafka]
via GitHub
-
2026/05/15
[jira] [Updated] (KAFKA-20591) Document restore.buffered.records.per.partition in Streams developer guide
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Updated] (KAFKA-20589) Add restore.buffered.records.per.partition config and enforce cap in StoreChangelogReader
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Updated] (KAFKA-20590) Add integration test coverage for restore.buffered.records.per.partition cap
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Comment Edited] (KAFKA-20585) Share Fetch latency metric incorrectly updated during ShareAcknowledgeResponse
Muralidhar Basani (Jira)
-
2026/05/15
[jira] [Updated] (KAFKA-19992) Allow to configure max memory for restore path
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Updated] (KAFKA-19992) Allow to configure max memory for restore path
Matthias J. Sax (Jira)
-
2026/05/15
[jira] [Comment Edited] (KAFKA-20585) Share Fetch latency metric incorrectly updated during ShareAcknowledgeResponse
Muralidhar Basani (Jira)
-
2026/05/15
[jira] [Commented] (KAFKA-20585) Share Fetch latency metric incorrectly updated during ShareAcknowledgeResponse
Muralidhar Basani (Jira)
-
2026/05/15
[jira] [Commented] (KAFKA-20585) Share Fetch latency metric incorrectly updated during ShareAcknowledgeResponse
Muralidhar Basani (Jira)
-
2026/05/15
[jira] [Assigned] (KAFKA-20585) Share Fetch latency metric incorrectly updated during ShareAcknowledgeResponse
Muralidhar Basani (Jira)
-
2026/05/15
[PR] KAFKA-20585 : Share Fetch latency metric incorrectly updated during ShareAcknowledgeResponse [kafka]
via GitHub
-
2026/05/15
Re: [PR] KAFKA-19483 : storage : Fix resource leak, cleanup [kafka]
via GitHub
-
2026/05/15
[jira] [Assigned] (KAFKA-20384) Per-Record Context Processing for Kafka Consumers
Aditya Kousik (Jira)
-
2026/05/15
[jira] [Assigned] (KAFKA-20385) Extend ConsumerRebalanceListener with Consumer-Aware methods
Aditya Kousik (Jira)
-
2026/05/15
[jira] [Assigned] (KAFKA-20386) SerDe and Interceptor Metrics
Aditya Kousik (Jira)
-
2026/05/15
[jira] [Assigned] (KAFKA-20387) Extend RecordHeader API for Common Value Types
Aditya Kousik (Jira)
-
2026/05/15
Re: [PR] MINOR: Scala to Java migration. Migrated some tests from PlaintextAdminIntegrationTest to a new java class. [kafka]
via GitHub
-
2026/05/15
Re: [PR] KAFKA-20430 Add configuration to control internal topic creation in Kafka Connect [kafka]
via GitHub
-
2026/05/15
[jira] [Resolved] (KAFKA-20575) Add onPartitionsLost support for MockConsumer
Aditya Kousik (Jira)
-
2026/05/15
[jira] [Assigned] (KAFKA-20575) Add onPartitionsLost support for MockConsumer
Aditya Kousik (Jira)
-
2026/05/15
Re: [PR] KAFKA-17689 Change TieredStorageTestContext to use ClusterInstance [kafka]
via GitHub
-
2026/05/15
Re: [PR] MINOR: avoid redundant HashMap lookups and simplify Uuid conversions [kafka]
via GitHub
-
2026/05/15
Re: [PR] KAFKA-17689 Change TieredStorageTestContext to use ClusterInstance [kafka]
via GitHub
-
2026/05/15
[jira] [Commented] (KAFKA-19491) Add documentation for missing AsyncKafkaConsumer metrics
Kirk True (Jira)
-
2026/05/15
[jira] [Closed] (KAFKA-20592) Fix several typos in Streams and upgrade documentation
Akhil Sabu (Jira)
-
2026/05/15
[jira] [Resolved] (KAFKA-20592) Fix several typos in Streams and upgrade documentation
Akhil Sabu (Jira)
-
2026/05/15
[jira] [Resolved] (KAFKA-20588) Add restore.buffered.records.per.partition to cap Kafka Streams state-restore memory
Muralidhar Basani (Jira)
-
2026/05/15
Re: [PR] KAFKA-17689 Change TieredStorageTestContext to use ClusterInstance [kafka]
via GitHub
-
2026/05/15
Re: [PR] KAFKA-17689 Change TieredStorageTestContext to use ClusterInstance [kafka]
via GitHub
-
2026/05/15
[jira] [Updated] (KAFKA-20496) Interactive Query isolation level configuration and framework
Bill Bejeck (Jira)
-
2026/05/15
[jira] [Updated] (KAFKA-20496) Interactive Query isolation level configuration and framework
Bill Bejeck (Jira)
-
2026/05/15
Re: [PR] KAFKA-20496: Add isolation level to IQ dispatch [kafka]
via GitHub
-
2026/05/15
Re: [PR] KAFKA-20496: Add isolation level to IQ dispatch [kafka]
via GitHub
-
2026/05/15
Re: [PR] KAFKA-20443: Move RequestChannel Requests to server module [kafka]
via GitHub
-
2026/05/15
[PR] MINOR: Use NullNode instead of empty TextNode for missing request/response fields [kafka]
via GitHub
-
2026/05/15
[jira] [Updated] (KAFKA-19790) Parsing of the scope claim does not comply with RFC-8693
Kirk True (Jira)
-
2026/05/15
[jira] [Commented] (KAFKA-19790) Parsing of the scope claim does not comply with RFC-8693
Kirk True (Jira)
-
2026/05/15
[jira] [Updated] (KAFKA-19790) Parsing of the scope claim does not comply with RFC-8693
Kirk True (Jira)
-
2026/05/15
Re: [PR] KAFKA-20419 : Add SASL_PLAINTEXT docker compose examples and sanity test [kafka]
via GitHub
-
2026/05/15
[jira] [Resolved] (KAFKA-20419) Add SASL docker compose examples for single-node and multi-node clusters
Viktor Somogyi-Vass (Jira)
-
2026/05/15
Re: [PR] KAFKA-20419 : Add SASL_PLAINTEXT docker compose examples and sanity test [kafka]
via GitHub
-
2026/05/15
Re: [PR] KAFKA-20570: Catch RuntimeException in ConsumerProtocol deserialization in group coordinator [kafka]
via GitHub
-
2026/05/15
Re: [PR] KAFKA-20570: Catch RuntimeException in ConsumerProtocol deserialization in group coordinator [kafka]
via GitHub
-
2026/05/15
[PR] KAFKA-17689 Change TieredStorageTestContext to use ClusterInstance [kafka]
via GitHub
-
2026/05/15
[jira] [Updated] (KAFKA-20575) Add onPartitionsLost support for MockConsumer
Aditya Kousik (Jira)
-
2026/05/15
[jira] [Resolved] (KAFKA-20564) Move AuthorizerTest to server module
Chia-Ping Tsai (Jira)
-
2026/05/15
Re: [PR] KAFKA-20564: Move AuthorizerTest to server [kafka]
via GitHub
-
2026/05/15
Re: [PR] KAFKA-20385 [1/N]: Add RebalanceConsumer interface and callback impl [kafka]
via GitHub
-
2026/05/15
[jira] [Assigned] (KAFKA-20592) Fix several typos in Streams and upgrade documentation
Sanskar Jhajharia (Jira)
-
2026/05/15
Re: [PR] KAFKA-20549: Add logic for create topic in DLQ state manager. [3/N] [kafka]
via GitHub
-
2026/05/15
Re: [PR] KAFKA-20592: Fixes some typos in Streams Documentation [kafka]
via GitHub
-
2026/05/15
[jira] [Created] (KAFKA-20593) Log a diagnostic warning at startup when Kafka Streams detects internal repartition topics
Ankur Sinha (Jira)
-
2026/05/15
[jira] [Closed] (KAFKA-20592) Fix several typos in Streams and upgrade documentation
Akhil Sabu (Jira)
-
2026/05/15
[jira] [Updated] (KAFKA-20592) Fix several typos in Streams and upgrade documentation
Akhil Sabu (Jira)
-
2026/05/15
[jira] [Resolved] (KAFKA-20592) Fix several typos in Streams and upgrade documentation
Akhil Sabu (Jira)
-
2026/05/15
[jira] [Reopened] (KAFKA-20592) Fix several typos in Streams and upgrade documentation
Sanskar Jhajharia (Jira)
-
2026/05/15
[jira] [Closed] (KAFKA-20592) Fix several typos in Streams and upgrade documentation
Akhil Sabu (Jira)
-
2026/05/15
[jira] [Resolved] (KAFKA-20592) Fix several typos in Streams and upgrade documentation
Akhil Sabu (Jira)
-
2026/05/15
[PR] KAFKA-20592: Fixes some typos in Streams Documentation [kafka]
via GitHub
-
2026/05/15
[jira] [Assigned] (KAFKA-20592) Fix several typos in Streams and upgrade documentation
Sanskar Jhajharia (Jira)
-
2026/05/15
[PR] MINOR: Prevent this leak while DefaultStatePersister construction. [kafka]
via GitHub
-
2026/05/15
Re: [PR] KAFKA-16876: TaskManager.handleRevocation doesn't handle errors thrown from task.prepareCommit [kafka]
via GitHub
-
2026/05/15
[jira] [Created] (KAFKA-20592) Fix several typos in Streams and upgrade documentation
Akhil Sabu (Jira)
-
2026/05/15
Re: [PR] KAFKA-20389: Filter internal keys from connector plugin config REST response [kafka]
via GitHub
-
2026/05/15
[jira] [Commented] (KAFKA-20587) Flaky : KafkaStreamsTelemetryIntegrationTest > "shouldPushGlobalThreadMetricsToBroker(String, String).recordingLevel=INFO, groupProtocol=streams
Nilesh Kumar (Jira)
-
2026/05/15
[jira] [Assigned] (KAFKA-20587) Flaky : KafkaStreamsTelemetryIntegrationTest > "shouldPushGlobalThreadMetricsToBroker(String, String).recordingLevel=INFO, groupProtocol=streams
Nilesh Kumar (Jira)
-
2026/05/15
[jira] [Commented] (KAFKA-20587) Flaky : KafkaStreamsTelemetryIntegrationTest > "shouldPushGlobalThreadMetricsToBroker(String, String).recordingLevel=INFO, groupProtocol=streams
Muralidhar Basani (Jira)
-
2026/05/15
Re: [PR] MINOR: avoid redundant HashMap lookups and simplify Uuid conversions [kafka]
via GitHub
-
2026/05/15
Re: [PR] KAFKA-20575: Add onPartitionsLost support for MockConsume [kafka]
via GitHub
-
2026/05/15
Re: [PR] MINOR: avoid redundant HashMap lookups and simplify Uuid conversions [kafka]
via GitHub
-
2026/05/15
Re: [PR] MINOR: Fix delegation token docs typo [kafka]
via GitHub
-
2026/05/15
[jira] [Commented] (KAFKA-20587) Flaky : KafkaStreamsTelemetryIntegrationTest > "shouldPushGlobalThreadMetricsToBroker(String, String).recordingLevel=INFO, groupProtocol=streams
Nilesh Kumar (Jira)
-
2026/05/15
Re: [PR] KAFKA-20566: Improve logging in share coordinator [kafka]
via GitHub
-
2026/05/15
[PR] KAFKA-20545: Fix flaky MirrorConnectorsIntegrationSSLTest testConnectorMetrics* tests [kafka]
via GitHub
-
2026/05/15
Re: [PR] MINOR: Scala to Java migration. Migrated some tests from PlaintextAdminIntegrationTest to a new java class. [kafka]
via GitHub
-
2026/05/15
Re: [PR] MINOR: avoid redundant HashMap lookups and simplify Uuid conversions [kafka]
via GitHub
-
2026/05/15
Re: [PR] KAFKA-14648: Do not fail clients if bootstrap servers is not immediately resolvable [kafka]
via GitHub
-
2026/05/15
Re: [PR] MINOR: avoid redundant HashMap lookups and simplify Uuid conversions [kafka]
via GitHub
-
2026/05/15
Re: [PR] MINOR: avoid redundant HashMap lookups and simplify Uuid conversions [kafka]
via GitHub
-
2026/05/15
Re: [PR] MINOR: avoid redundant HashMap lookups and simplify Uuid conversions [kafka]
via GitHub
-
2026/05/15
Re: [PR] MINOR: avoid redundant HashMap lookups and simplify Uuid conversions [kafka]
via GitHub
-
2026/05/15
Re: [PR] KAFKA-20564: Move AuthorizerTest to server [kafka]
via GitHub
-
2026/05/15
Re: [PR] MINOR: Assert queryable state range results [kafka]
via GitHub
-
2026/05/15
Re: [PR] MINOR: Prefer MetadataRecordSerde.INSTANCE over new instances [kafka]
via GitHub
-
2026/05/15
Re: [PR] MINOR: Prefer MetadataRecordSerde.INSTANCE over new instances [kafka]
via GitHub
-
2026/05/15
Re: [PR] MINOR: Prefer MetadataRecordSerde.INSTANCE over new instances [kafka]
via GitHub
-
2026/05/15
Re: [PR] KAFKA-20385 [1/N]: Add RebalanceConsumer interface and callback impl [kafka]
via GitHub
-
2026/05/15
Re: [PR] MINOR: Prefer MetadataRecordSerde.INSTANCE over new instances [kafka]
via GitHub
-
2026/05/15
[jira] [Resolved] (KAFKA-20574) SimpleConfigRepository in the storage module could be replaced by MockConfigRepository
Chia-Ping Tsai (Jira)
-
2026/05/15
Re: [PR] KAFKA-20574 : SimpleConfigRepository in the storage module could be replaced by MockConfigRepository [kafka]
via GitHub
-
2026/05/15
Re: [PR] MINOR: Update javadocs for GroupConfig and GroupConfigManager [kafka]
via GitHub
-
2026/05/14
Re: [PR] MINOR: Assert queryable state range results [kafka]
via GitHub
-
2026/05/14
Re: [PR] KAFKA-20564: Move AuthorizerTest to server [kafka]
via GitHub