Messages by Thread
-
[PR] MINOR: Separate gradle config of `QA` plugins [kafka]
via GitHub
-
Re: [PR] MINOR: Separate gradle config of `QA` plugins [kafka]
via GitHub
-
Re: [PR] MINOR: Separate gradle config of `QA` plugins [kafka]
via GitHub
-
Re: [PR] MINOR: Separate gradle config of `QA` plugins [kafka]
via GitHub
-
Re: [PR] MINOR: Separate gradle config of `QA` plugins [kafka]
via GitHub
-
Re: [PR] MINOR: Separate gradle config of `QA` plugins [kafka]
via GitHub
-
Re: [PR] MINOR: Separate gradle config of `QA` plugins [kafka]
via GitHub
-
Re: [PR] MINOR: Split gradle plugin config of `quality gates` (spotless, spotbugs, and checkstyle) into dedicated files [kafka]
via GitHub
-
Re: [PR] MINOR: Split gradle plugin config of `quality gates` (spotless, spotbugs, and checkstyle) into dedicated files [kafka]
via GitHub
-
Re: [PR] MINOR: Split gradle plugin config of `quality gates` (spotless, spotbugs, and checkstyle) into dedicated files [kafka]
via GitHub
-
Re: [PR] MINOR: Split gradle plugin config of `quality gates` (spotless, spotbugs, and checkstyle) into dedicated files [kafka]
via GitHub
-
Re: [PR] MINOR: Split gradle plugin config of `quality gates` (spotless, spotbugs, and checkstyle) into dedicated files [kafka]
via GitHub
-
Re: [PR] MINOR: Split gradle plugin config of `quality gates` (spotless, spotbugs, and checkstyle) into dedicated files [kafka]
via GitHub
-
Re: [PR] MINOR: Split gradle root config into dedicated sections [kafka]
via GitHub
-
Re: [PR] MINOR: Split gradle root config into dedicated sections [kafka]
via GitHub
-
Re: [PR] MINOR: Split gradle root config into dedicated sections [kafka]
via GitHub
-
[jira] [Assigned] (KAFKA-19562) Rewrite AbortedTxn by generated protocol
Ming-Yen Chung (Jira)
-
[jira] [Created] (KAFKA-19562) Rewrite AbortedTxn by generated protocol
Chia-Ping Tsai (Jira)
-
Re: [PR] KAFKA-18913: Removing _state.updater.enabled_ flag through the Stream… [kafka]
via GitHub
-
Re: [PR] KAFKA-1826 [1/N]: Introducing GroupStore [kafka]
via GitHub
-
Re: [PR] KAFKA-16653: Remove delayed initialization because of static voter set [kafka]
via GitHub
-
Re: [PR] KAFKA-10357 Refactor makeReady to reduce complexity and support upcoming KIP-698 changes [kafka]
via GitHub
-
Re: [PR] KAFKA-15599: Move KafkaMetadataLog to the raft module [kafka]
via GitHub
-
[PR] KAFKA-19561: Set OP_WRITE interest after server SASL reauthentication to resume pending writes [kafka]
via GitHub
-
[jira] [Updated] (KAFKA-19561) Request Timeout During SASL Reauthentication Due to Missed OP_WRITE interest set
Manikumar (Jira)
-
[jira] [Created] (KAFKA-19561) Request Timeout During SASL Reauthentication Due to Missed OP_WRITE interest set
Manikumar (Jira)
-
[jira] [Updated] (KAFKA-19532) Kafka request metric discrepancies
Jess (Jira)
-
[jira] [Commented] (KAFKA-19012) Messages ending up on the wrong topic
Jun Rao (Jira)
-
Re: [PR] MINOR: Upgrade log4j to version 2.25.1 [kafka]
via GitHub
-
[jira] [Resolved] (KAFKA-19530) RemoteLogManager should record lag stats when remote storage is offline
Kamal Chandraprakash (Jira)
-
[jira] [Resolved] (KAFKA-19484) Tiered Storage Quota Metrics can stop reporting
Kamal Chandraprakash (Jira)
-
[PR] fix: replace deprecated wmic with env variables [kafka]
via GitHub
-
[PR] KAFKA-15038: Replace topicIdByPartitionMap with MetadataCache instance in RemoteLogManager [kafka]
via GitHub
-
Re: [PR] KAFKA-19493: Incorrect rate metric with larger window size [kafka]
via GitHub
-
Re: [PR] MINOR: Cleanups in storage module [kafka]
via GitHub
-
[jira] [Commented] (KAFKA-19409) Upgrade RocksDB dependency from 10.1.3 to something newer
Rajani Karuturi (Jira)
-
[jira] [Resolved] (KAFKA-16717) Add AdminClient.alterShareGroupOffsets
Andrew Schofield (Jira)
-
[jira] [Resolved] (KAFKA-19555) Restrict records acquisition post max inflight records
Apoorv Mittal (Jira)
-
[jira] [Updated] (KAFKA-19560) leader of the __consumer_offsets topic is not balanced
mooner (Jira)
-
[jira] [Created] (KAFKA-19560) leader of the __consumer_offsets topic is not balanced
mooner (Jira)
-
[PR] KAFKA-19559: Remove ShareFetchMetricsManager sensors on consumer.close() [kafka]
via GitHub
-
[jira] [Created] (KAFKA-19559) ShareConsumer.close() does not remove all sensors.
Shivsundar R (Jira)
-
[jira] [Assigned] (KAFKA-19559) ShareConsumer.close() does not remove all sensors.
Shivsundar R (Jira)
-
[jira] [Commented] (KAFKA-19532) Kafka request metric discrepancies
Ksolves India Limited (Jira)
-
[jira] [Assigned] (KAFKA-19532) Kafka request metric discrepancies
Ksolves India Limited (Jira)
-
[jira] (KAFKA-19479) at_least_once mode in Kafka Streams silently drops messages when the producer fails with MESSAGE_TOO_LARGE, violating delivery guarantees
Shashank (Jira)
-
[jira] [Commented] (KAFKA-12281) Cleanup unused org.apache.kafka.streams.errors.BrokerNotFoundException
Rajani Karuturi (Jira)
-
Re: [PR] KIP-891: Multiversioning in Kafka Connect - Config and Validation Tests [kafka]
via GitHub
-
Re: [PR] KAFKA-19527: improve the docs of LogDirDescription for remote storage [kafka]
via GitHub
-
[jira] [Updated] (KAFKA-19558) kafka-consumer-groups.sh --describe --all-groups command times out on large clusters with many consumer groups
zhangtongr (Jira)
-
[jira] [Created] (KAFKA-19558) kafka-consumer-groups.sh --describe --all-groups command times out on large clusters with many consumer groups
zhangtongr (Jira)
-
[PR] KAFKA-19479: at_least_once mode in Kafka Streams silently drops messages when the producer fails with MESSAGE_TOO_LARGE, violating delivery guarantees [kafka]
via GitHub
-
[jira] [Updated] (KAFKA-19434) Move logic for for state store initiation to StreamThread handover
Matthias J. Sax (Jira)
-
Re: [PR] KAFKA-18066: Fix mismatched StreamThread ID in log messages [kafka]
via GitHub
-
[jira] [Assigned] (KAFKA-16505) KIP-1034: Dead letter queue in Kafka Streams
Matthias J. Sax (Jira)
-
[jira] [Updated] (KAFKA-16505) KIP-1034: Dead letter queue in Kafka Streams
Matthias J. Sax (Jira)
-
[jira] [Updated] (KAFKA-17281) Remove old PAPI methods
Matthias J. Sax (Jira)
-
[jira] [Updated] (KAFKA-17537) Remove deprecates methods from Joined class
Matthias J. Sax (Jira)
-
[jira] [Updated] (KAFKA-17538) Make deprecated *_DOC variable private/package-private
Matthias J. Sax (Jira)
-
[jira] [Updated] (KAFKA-17280) Remove deprecated methods from DeserializationExceptionHandler as ProductionExceptionHandler
Matthias J. Sax (Jira)
-
[jira] [Updated] (KAFKA-19557) Remove BrokerNotFoundException
Matthias J. Sax (Jira)
-
[jira] [Created] (KAFKA-19557) Remove BrokerNotFoundException
Matthias J. Sax (Jira)
-
[jira] [Resolved] (KAFKA-12281) Cleanup unused org.apache.kafka.streams.errors.BrokerNotFoundException
Matthias J. Sax (Jira)
-
Re: [PR] KAFKA-19506 : Implement dynamic compression type selection and fallback for client telemetry [kafka]
via GitHub