jira
Thread
Date
Earlier messages
Later messages
Messages by Thread
Re: [PR] KAFKA-16630: Fix flaky classic consumer poll test [kafka]
via GitHub
[jira] [Assigned] (KAFKA-16630) Flaky test "testPollReturnsRecords(GroupProtocol).groupProtocol=CLASSIC" – org.apache.kafka.clients.consumer.KafkaConsumerTest
Lianet Magrans (Jira)
[jira] [Commented] (KAFKA-16630) Flaky test "testPollReturnsRecords(GroupProtocol).groupProtocol=CLASSIC" – org.apache.kafka.clients.consumer.KafkaConsumerTest
Lianet Magrans (Jira)
[jira] [Assigned] (KAFKA-20752) Respect Logical Type in timestamp serialization to prevent truncation
majialong (Jira)
[jira] [Commented] (KAFKA-20752) Respect Logical Type in timestamp serialization to prevent truncation
majialong (Jira)
[jira] [Updated] (KAFKA-20778) Improve classic consumer rack-aware double rebalance on replica bounce
Lianet Magrans (Jira)
[jira] [Resolved] (KAFKA-20778) Improve classic consumer rack-aware double rebalance on replica bounce
Lianet Magrans (Jira)
[jira] [Updated] (KAFKA-20534) Consider decoupling AsyncPollEvent reconciliation trigger and position validation/reset
Lianet Magrans (Jira)
[jira] [Resolved] (KAFKA-20751) Cached connector plugin version validation failures lose available versions on repeated validation
Mickael Maison (Jira)
[jira] [Assigned] (KAFKA-20780) syncKafkaConsumer does not keep a fetch request pending on the broker, causing latency and throughput regressions vs the classic consumer
Lianet Magrans (Jira)
[jira] [Resolved] (KAFKA-20703) Implement query type 1 (TimestampedKeyQueryWithHeaders)
Jess Jin (Jira)
[jira] [Updated] (KAFKA-20722) fix GHSA-47qp-hqvx-6r3f and GHSA-2r2c-cx56-8933
Krishna Chidrawar (Jira)
[PR] KAFKA-20772 (1/n): Add DLQ system tests for single-partition share group scenarios [kafka]
via GitHub
Re: [PR] KAFKA-20772 (1/n): Add DLQ system tests for single-partition share group scenarios [kafka]
via GitHub
Re: [PR] KAFKA-20772 (1/n): Add DLQ system tests for single-partition share group scenarios [kafka]
via GitHub
Re: [PR] KAFKA-20772 (1/n): Add DLQ system tests for single-partition share group scenarios [kafka]
via GitHub
Re: [PR] KAFKA-20772 (1/n): Add DLQ system tests for single-partition share group scenarios [kafka]
via GitHub
Re: [PR] KAFKA-20772 (1/n): Add DLQ system tests for single-partition share group scenarios [kafka]
via GitHub
Re: [PR] KAFKA-20772 (1/n): Add DLQ system tests for single-partition share group scenarios [kafka]
via GitHub
Re: [PR] KAFKA-20772 (1/n): Add DLQ system tests for single-partition share group scenarios [kafka]
via GitHub
Re: [PR] KAFKA-20772 (1/n): Add DLQ system tests for single-partition share group scenarios [kafka]
via GitHub
Re: [PR] KAFKA-20772 (1/n): Add DLQ system tests for single-partition share group scenarios [kafka]
via GitHub
Re: [PR] KAFKA-20772 (1/n): Add DLQ system tests for single-partition share group scenarios [kafka]
via GitHub
Re: [PR] KAFKA-20772 (1/n): Add DLQ system tests for single-partition share group scenarios [kafka]
via GitHub
Re: [PR] KAFKA-20772 (1/n): Add DLQ system tests for single-partition share group scenarios [kafka]
via GitHub
Re: [PR] KAFKA-20772 (1/n): Add DLQ system tests for single-partition share group scenarios [kafka]
via GitHub
Re: [PR] KAFKA-20772 (1/n): Add DLQ system tests for single-partition share group scenarios [kafka]
via GitHub
Re: [PR] KAFKA-20772 (1/n): Add DLQ system tests for single-partition share group scenarios [kafka]
via GitHub
Re: [PR] KAFKA-20772 (1/n): Add DLQ system tests for single-partition share group scenarios [kafka]
via GitHub
Re: [PR] KAFKA-20772 (1/n): Add DLQ system tests for single-partition share group scenarios [kafka]
via GitHub
Re: [PR] Rlm [kafka]
via GitHub
Re: [PR] Rlm [kafka]
via GitHub
Re: [PR] KAFKA-15899: [2/2] Move kafka.security package from core to server module [kafka]
via GitHub
Re: [PR] KAFKA-15899: [2/2] Move kafka.security package from core to server module [kafka]
via GitHub
Re: [PR] KAFKA-15899: [2/2] Move kafka.security package from core to server module [kafka]
via GitHub
Re: [PR] KAFKA-15899: [2/2] Move kafka.security package from core to server module [kafka]
via GitHub
Re: [PR] KAFKA-20155: Implement lazy header deserialization for state stores [kafka]
via GitHub
Re: [PR] KAFKA-20155: Implement lazy header deserialization for state stores [kafka]
via GitHub
Re: [PR] KAFKA-20400: Enable VersionedKeyValueStoreWithHeaders in DSL [kafka]
via GitHub
Re: [PR] KAFKA-20400: Enable VersionedKeyValueStoreWithHeaders in DSL [kafka]
via GitHub
Re: [PR] KAFKA-20400: Enable VersionedKeyValueStoreWithHeaders in DSL [kafka]
via GitHub
Re: [PR] KAFKA-15853: [2/N] Move bulk of remaining configs to AbstractKafkaConfig [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] [WIP] KIP-966: Designated Leadership elections [kafka]
via GitHub
Re: [PR] [WIP] KIP-966: Designated Leadership elections [kafka]
via GitHub
Re: [PR] KAFKA-19615: Enable to ducker-ak to isolate the ducker containers [kafka]
via GitHub
Re: [PR] KAFKA-19615: Enable to ducker-ak to isolate the ducker containers [kafka]
via GitHub
Re: [PR] KAFKA 18238 - fIdentify the first commit where a test became flaky [kafka]
via GitHub
Re: [PR] KAFKA 18238 - fIdentify the first commit where a test became flaky [kafka]
via GitHub
Re: [PR] KAFKA-19086: Add support for microsecond precision for Connect [kafka]
via GitHub
Re: [PR] KAFKA-19086: Add support for microsecond precision for Connect [kafka]
via GitHub
Re: [PR] KAFKA-19086: Add support for microsecond precision for Connect [kafka]
via GitHub
[PR] MINOR: Speed up AuthorizerIntegrationTest [kafka]
via GitHub
Re: [PR] MINOR: Speed up AuthorizerIntegrationTest [kafka]
via GitHub
Re: [PR] MINOR: Speed up AuthorizerIntegrationTest [kafka]
via GitHub
Re: [PR] MINOR: Speed up AuthorizerIntegrationTest [kafka]
via GitHub
Re: [PR] MINOR: Speed up AuthorizerIntegrationTest [kafka]
via GitHub
Re: [PR] MINOR: Speed up AuthorizerIntegrationTest [kafka]
via GitHub
Re: [PR] MINOR: Speed up AuthorizerIntegrationTest [kafka]
via GitHub
Re: [PR] MINOR: Speed up AuthorizerIntegrationTest [kafka]
via GitHub
[PR] KAFKA-20539 Prevent Hot Data Loss on Partition Expansion for Latest Policy [kafka]
via GitHub
Re: [PR] KAFKA-20539 Prevent Hot Data Loss on Partition Expansion for Latest Policy [kafka]
via GitHub
Re: [PR] KAFKA-20539 Prevent Hot Data Loss on Partition Expansion for Latest Policy [kafka]
via GitHub
Re: [PR] KAFKA-20539 Prevent Hot Data Loss on Partition Expansion for Latest Policy [kafka]
via GitHub
Re: [PR] KAFKA-20539 Prevent Hot Data Loss on Partition Expansion for Latest Policy [kafka]
via GitHub
Re: [PR] KAFKA-20539 Prevent Hot Data Loss on Partition Expansion for Latest Policy [kafka]
via GitHub
Re: [PR] KAFKA-20539 Prevent Hot Data Loss on Partition Expansion for Latest Policy [kafka]
via GitHub
[PR] KAFKA-20719: "Streams" group sticky assignor not sticky at startup [kafka]
via GitHub
Re: [PR] KAFKA-20719: "Streams" group sticky assignor not sticky at startup [kafka]
via GitHub
[jira] [Created] (KAFKA-20786) Build sometimes times out on streams tests
Lianet Magrans (Jira)
[PR] MINOR: Replace deprecated TopologyTestDriver constructor in TestTopicsTest [kafka]
via GitHub
Re: [PR] MINOR: Replace deprecated TopologyTestDriver constructor in TestTopicsTest [kafka]
via GitHub
[jira] [Commented] (KAFKA-15104) Flaky test MetadataQuorumCommandTest for method testDescribeQuorumReplicationSuccessful
Lianet Magrans (Jira)
[PR] MINOR: mark flaky test [kafka]
via GitHub
Re: [PR] MINOR: mark flaky testDescribeQuorumReplicationSuccessful [kafka]
via GitHub
[jira] [Created] (KAFKA-20785) Unexpected InvalidTxnStateException on EndTxn when commit races with transaction timeout
Lianet Magrans (Jira)
[PR] KAFKA-20783: Integrate async log reader fetch in DelayedShareFetch (1/N) [kafka]
via GitHub
Re: [PR] KAFKA-20783: Integrate async log reader fetch in DelayedShareFetch (1/N) [kafka]
via GitHub
Re: [PR] KAFKA-20783: Integrate async log reader fetch in DelayedShareFetch (1/N) [kafka]
via GitHub
Re: [PR] KAFKA-20783: Integrate async log reader fetch in DelayedShareFetch (1/N) [kafka]
via GitHub
Re: [PR] KAFKA-20783: Integrate async log reader fetch in DelayedShareFetch (1/N) [kafka]
via GitHub
Re: [PR] KAFKA-20783: Integrate async log reader fetch in DelayedShareFetch (1/N) [kafka]
via GitHub
Re: [PR] KAFKA-20783: Integrate async log reader fetch in DelayedShareFetch (1/N) [kafka]
via GitHub
Re: [PR] KAFKA-20783: Integrate async log reader fetch in DelayedShareFetch (1/N) [kafka]
via GitHub
Re: [PR] KAFKA-20783: Integrate async log reader fetch in DelayedShareFetch (1/N) [kafka]
via GitHub
Re: [PR] KAFKA-20783: Integrate async log reader fetch in DelayedShareFetch (1/N) [kafka]
via GitHub
Re: [PR] KAFKA-20783: Integrate async log reader fetch in DelayedShareFetch (1/N) [kafka]
via GitHub
Re: [PR] KAFKA-20783: Integrate async log reader fetch in DelayedShareFetch (1/N) [kafka]
via GitHub
Re: [PR] KAFKA-20783: Integrate async log reader fetch in DelayedShareFetch (1/N) [kafka]
via GitHub
Re: [PR] KAFKA-20783: Integrate async log reader fetch in DelayedShareFetch (1/N) [kafka]
via GitHub
Re: [PR] KAFKA-20783: Integrate async log reader fetch in DelayedShareFetch (1/N) [kafka]
via GitHub
Re: [PR] KAFKA-20783: Integrate async log reader fetch in DelayedShareFetch (1/N) [kafka]
via GitHub
Re: [PR] KAFKA-20783: Integrate async log reader fetch in DelayedShareFetch (1/N) [kafka]
via GitHub
Re: [PR] KAFKA-20783: Integrate async log reader fetch in DelayedShareFetch (1/N) [kafka]
via GitHub
Re: [PR] KAFKA-20783: Integrate async log reader fetch in DelayedShareFetch (1/N) [kafka]
via GitHub
[jira] [Assigned] (KAFKA-20782) IQ returns 1/N metadata when Streams protocol and N threads
Uladzislau Blok (Jira)
[jira] [Created] (KAFKA-20784) Change certificate management
Jira
[jira] [Created] (KAFKA-20783) Integrate async log reader fetch in DelayedShareFetch
Apoorv Mittal (Jira)
[PR] MINOR: Move Log4jControllerRegistration to server module [kafka]
via GitHub
Re: [PR] MINOR: Move Log4jControllerRegistration to server module [kafka]
via GitHub
Re: [PR] MINOR: Move Log4jControllerRegistration to server module [kafka]
via GitHub
Re: [PR] MINOR: Move Log4jControllerRegistration to server module [kafka]
via GitHub
Re: [PR] MINOR: Move Log4jControllerRegistration to server module [kafka]
via GitHub
Re: [PR] MINOR: Move Log4jControllerRegistration to server module [kafka]
via GitHub
Re: [PR] MINOR: Move Log4jControllerRegistration to server module [kafka]
via GitHub
Re: [PR] MINOR: Move Log4jControllerRegistration to server module [kafka]
via GitHub
[jira] [Assigned] (KAFKA-20773) [CVE-2026-54515][jackson-databind]
Mickael Maison (Jira)
[jira] [Assigned] (KAFKA-20773) [CVE-2026-54515][jackson-databind]
Federico Valeri (Jira)
[jira] [Assigned] (KAFKA-20781) Flaky testConsumerGroupHeartbeatWithRegexWithDifferentMemberAcls
Lianet Magrans (Jira)
[jira] [Created] (KAFKA-20782) IQ returns 1/N metadata when Streams protocol and N threads
Uladzislau Blok (Jira)
[jira] [Updated] (KAFKA-20782) IQ returns 1/N metadata when Streams protocol and N threads
Uladzislau Blok (Jira)
[jira] [Updated] (KAFKA-20782) IQ returns 1/N metadata when Streams protocol and N threads
Uladzislau Blok (Jira)
[jira] [Updated] (KAFKA-20782) IQ returns 1/N metadata when Streams protocol and N threads
Uladzislau Blok (Jira)
[jira] [Updated] (KAFKA-20782) IQ returns 1/N metadata when Streams protocol and N threads
Uladzislau Blok (Jira)
[jira] [Updated] (KAFKA-20782) IQ returns 1/N metadata when Streams protocol and N threads
Uladzislau Blok (Jira)
[jira] [Updated] (KAFKA-20782) IQ returns 1/N metadata when Streams protocol and N threads
Matthias J. Sax (Jira)
[PR] KAKFA-XXX: IQ bug under streams protocol [kafka]
via GitHub
Re: [PR] KAKFA-XXX: IQ bug under streams protocol [kafka]
via GitHub
Re: [PR] KAFKA-20782: IQ bug under streams protocol [kafka]
via GitHub
Re: [PR] KAFKA-20782: IQ bug under streams protocol [kafka]
via GitHub
[jira] [Commented] (KAFKA-20781) Flaky testConsumerGroupHeartbeatWithRegexWithDifferentMemberAcls
Nilesh Kumar (Jira)
[jira] [Commented] (KAFKA-20781) Flaky testConsumerGroupHeartbeatWithRegexWithDifferentMemberAcls
Lianet Magrans (Jira)
[jira] [Created] (KAFKA-20781) Flaky testConsumerGroupHeartbeatWithRegexWithDifferentMemberAcls
Lianet Magrans (Jira)
[jira] [Updated] (KAFKA-18812) Improve new consumer API errors upon background thread failures
Lianet Magrans (Jira)
[jira] [Resolved] (KAFKA-18812) Improve new consumer API errors upon background thread failures
Lianet Magrans (Jira)
[jira] [Commented] (KAFKA-20780) syncKafkaConsumer does not keep a fetch request pending on the broker, causing latency and throughput regressions vs the classic consumer
Lianet Magrans (Jira)
[jira] [Commented] (KAFKA-20780) syncKafkaConsumer does not keep a fetch request pending on the broker, causing latency and throughput regressions vs the classic consumer
Jira
[jira] [Commented] (KAFKA-20780) syncKafkaConsumer does not keep a fetch request pending on the broker, causing latency and throughput regressions vs the classic consumer
Lianet Magrans (Jira)
[PR] KAFKA-20748: Keep StoredDescriptionTopologyEpoch consistent with the topology description plugin [kafka]
via GitHub
Re: [PR] KAFKA-20748: Keep StoredDescriptionTopologyEpoch consistent with the topology description plugin [kafka]
via GitHub
Re: [PR] KAFKA-20748: Keep StoredDescriptionTopologyEpoch consistent with the topology description plugin [kafka]
via GitHub
Re: [PR] KAFKA-20748: Keep StoredDescriptionTopologyEpoch consistent with the topology description plugin [kafka]
via GitHub
Re: [PR] KAFKA-20748: Keep StoredDescriptionTopologyEpoch consistent with the topology description plugin [kafka]
via GitHub
Re: [PR] KAFKA-20748: Keep StoredDescriptionTopologyEpoch consistent with the topology description plugin [kafka]
via GitHub
[PR] KAFKA-20630: Add documentation for topology description plugin feature [kafka]
via GitHub
Re: [PR] KAFKA-20630: Add documentation for topology description plugin feature [kafka]
via GitHub
Re: [PR] KAFKA-20630: Add documentation for topology description plugin feature [kafka]
via GitHub
Re: [PR] KAFKA-20630: Add documentation for topology description plugin feature [kafka]
via GitHub
Re: [PR] KAFKA-20630: Add documentation for topology description plugin feature [kafka]
via GitHub
[PR] KAFKA-20627: Add broker integration tests for topology description plugin [kafka]
via GitHub
Re: [PR] KAFKA-20627: Add broker integration tests for topology description plugin [kafka]
via GitHub
Re: [PR] KAFKA-20627: Add broker integration tests for topology description plugin [kafka]
via GitHub
[PR] KIP-1266: Send keyed events to the remote log metadata topic [kafka]
via GitHub
Re: [PR] KIP-1266: Send keyed events to the remote log metadata topic [kafka]
via GitHub
Re: [PR] KIP-1266: Send keyed events to the remote log metadata topic [kafka]
via GitHub
Re: [PR] KIP-1266: Send keyed events to the remote log metadata topic [kafka]
via GitHub
Re: [PR] KIP-1266: Send keyed events to the remote log metadata topic [kafka]
via GitHub
Re: [PR] KIP-1266: Send keyed events to the remote log metadata topic [kafka]
via GitHub
Re: [PR] KIP-1266: Send keyed events to the remote log metadata topic [kafka]
via GitHub
Re: [PR] KIP-1266: Send keyed events to the remote log metadata topic [kafka]
via GitHub
Re: [PR] KIP-1266: Send keyed events to the remote log metadata topic [kafka]
via GitHub
[PR] KAFKA: Fix typo in GroupMetadataManagerTest comments (inital -> initial) [kafka]
via GitHub
Re: [PR] MINOR: Fix typos in GroupMetadataManagerTest comments [kafka]
via GitHub
[jira] [Created] (KAFKA-20780) syncKafkaConsumer does not keep a fetch request pending on the broker, causing latency and throughput regressions vs the classic consumer
Jira
Re: [PR] KAFKA-19651: Restore thread interrupted status in consumer close() [kafka]
via GitHub
Re: [PR] [TEST] check tags order [kafka]
via GitHub
[PR] KAFKA-20779: KIP-1265 review follow-ups from #21337 [kafka]
via GitHub
Re: [PR] KAFKA-20779: KIP-1265 review follow-ups from #21337 [kafka]
via GitHub
Re: [PR] KAFKA-20779: KIP-1265 review follow-ups from #21337 [kafka]
via GitHub
Re: [PR] KAFKA-20779: KIP-1265 review follow-ups from #21337 [kafka]
via GitHub
[jira] [Updated] (KAFKA-20779) followup review on the merged KIP-1265 PR
Ashwin Pankaj (Jira)
[jira] [Updated] (KAFKA-20779) followup review on the merged KIP-1265 PR
Ashwin Pankaj (Jira)
[jira] [Created] (KAFKA-20779) followup review on the merged KIP-1265 PR [https://github.com/apache/kafka/pull/21337]
Ashwin Pankaj (Jira)
[PR] MINOR: Fix malformed UnifiedLog log messages [kafka]
via GitHub
Re: [PR] MINOR: Fix malformed UnifiedLog log messages [kafka]
via GitHub
Re: [PR] KAFKA-6416: Helm chart for deploying Kafka to Kubernetes [kafka]
via GitHub
[PR] KAFKA-20704: IQv2 TimestampedRangeWithHeadersQuery for headers-aware key-value stores (KIP-1356) [kafka]
via GitHub
Re: [PR] KAFKA-20704: IQv2 TimestampedRangeWithHeadersQuery for headers-aware key-value stores (KIP-1356) [kafka]
via GitHub
Re: [PR] KAFKA-20704: IQv2 TimestampedRangeWithHeadersQuery for headers-aware key-value stores (KIP-1356) [kafka]
via GitHub
Re: [PR] KAFKA-20704: IQv2 TimestampedRangeWithHeadersQuery for headers-aware key-value stores (KIP-1356) [kafka]
via GitHub
Re: [PR] KAFKA-20704: IQv2 TimestampedRangeWithHeadersQuery for headers-aware key-value stores (KIP-1356) [kafka]
via GitHub
Re: [PR] KAFKA-20704: IQv2 TimestampedRangeWithHeadersQuery for headers-aware key-value stores (KIP-1356) [kafka]
via GitHub
Re: [PR] KAFKA-20704: IQv2 TimestampedRangeWithHeadersQuery for headers-aware key-value stores (KIP-1356) [kafka]
via GitHub
Re: [PR] KAFKA-20765: Fix OffsetFetch stale-epoch retry spinning in dedup loop [kafka]
via GitHub
Re: [PR] KAFKA-20765: Fix OffsetFetch stale-epoch retry spinning in dedup loop [kafka]
via GitHub
[PR] KAFKA-20778: Avoid unneeded rebalance on classic consumer when replica unavailable [kafka]
via GitHub
Re: [PR] KAFKA-20778: Avoid unneeded rebalance on classic consumer when replica unavailable [kafka]
via GitHub
Re: [PR] KAFKA-20778: Avoid unneeded rebalance on classic consumer when replica unavailable [kafka]
via GitHub
Re: [PR] KAFKA-20778: Avoid unneeded rebalance on classic consumer when replica unavailable [kafka]
via GitHub
Re: [PR] KAFKA-20778: Avoid unneeded rebalance on classic consumer when replica unavailable [kafka]
via GitHub
[PR] KAFKA-20629: Add ducktape system tests for topology description plugin[2/2] [kafka]
via GitHub
Re: [PR] KAFKA-20629: Add ducktape system tests for topology description plugin[2/2] [kafka]
via GitHub
[jira] [Created] (KAFKA-20778) Improve classic consumer rack-aware double rebalance on replica bounce
Lianet Magrans (Jira)
[jira] [Created] (KAFKA-20777) StagedMergeIterator throws IllegalStateException instead of InvalidStateStoreException when used after store close
Alan Lau (Jira)
[PR] KAFKA-20736: Improve share session handling on leader change [kafka]
via GitHub
Re: [PR] KAFKA-20736: Improve share session handling on leader change [kafka]
via GitHub
Re: [PR] KAFKA-20736: Improve share session handling on leader change [kafka]
via GitHub
Re: [PR] KAFKA-20736: Improve share session handling on leader change [kafka]
via GitHub
Re: [PR] KAFKA-20736: Improve share session handling on leader change [kafka]
via GitHub
Re: [PR] KAFKA-20736: Improve share session handling on leader change [kafka]
via GitHub
Re: [PR] KAFKA-20736: Improve share session handling on leader change [kafka]
via GitHub
Re: [PR] KAFKA-20391: Improve types returned by the Connect REST API [kafka]
via GitHub
[PR] KAFKA-20297 Move ChildFirstClassLoader, ProducerIdAndEpoch into internal [kafka]
via GitHub
Re: [PR] KAFKA-20297 Move ChildFirstClassLoader, ProducerIdAndEpoch into internal [kafka]
via GitHub
[PR] MINOR: Move RequestChannelTest to server module [kafka]
via GitHub
Re: [PR] MINOR: Move RequestChannelTest to server module [kafka]
via GitHub
[jira] [Created] (KAFKA-20776) MeteredKeyValueStore / MeteredTimestampedKeyValueStore ignore skipCache() for KeyQuery and TimestampedKeyQuery
Jess Jin (Jira)
[jira] [Updated] (KAFKA-20776) MeteredKeyValueStore / MeteredTimestampedKeyValueStore ignore skipCache() for KeyQuery and TimestampedKeyQuery
Jess Jin (Jira)
[jira] [Assigned] (KAFKA-19117) Client Throttling Log messages should be of log level - WARN (Java client)
Chia-Ping Tsai (Jira)
Earlier messages
Later messages