jira
Thread
Date
Earlier messages
Messages by Thread
[jira] [Commented] (KAFKA-19508) Producer keeps reporting a NotLeaderOrFollowerException
wangqingyu (Jira)
[jira] [Updated] (KAFKA-19521) Fix consumption and leaving group when source topic is deleted
Matthias J. Sax (Jira)
[PR] (WIP) MINOR: Migrate EligibleLeaderReplicasIntegrationTestto use new test infra [kafka]
via GitHub
[jira] [Resolved] (KAFKA-4705) ConfigDef should support deprecated keys as synonyms
Colin McCabe (Jira)
[jira] [Created] (KAFKA-19521) Fix consumption and leaving group when source topic is deleted
travis (Jira)
[PR] MINOR:Extract public code [kafka]
via GitHub
Re: [PR] MINOR:Extract public code [kafka]
via GitHub
Re: [PR] MINOR:Extract public code [kafka]
via GitHub
[PR] Feature/openj9 integration [kafka]
via GitHub
[PR] KAFKA-19520 Bump Commons-Lang for CVE-2025-48924 [kafka]
via GitHub
Re: [PR] KAFKA-19520 Bump Commons-Lang for CVE-2025-48924 [kafka]
via GitHub
[jira] [Assigned] (KAFKA-19520) Bump Commons-Lang for CVE-2025-48924
Dmitry Werner (Jira)
[jira] [Created] (KAFKA-19520) Bump Commons-Lang for CVE-2025-48924
Luke Chen (Jira)
[jira] [Assigned] (KAFKA-19519) Introduce a new config for group coordinator max record size
Chia-Ping Tsai (Jira)
[jira] [Commented] (KAFKA-18209) Cleanup __transaction_state config logic
Ksolves India Limited (Jira)
[jira] [Commented] (KAFKA-19519) Introduce a new config for group coordinator max record size
Lan Ding (Jira)
[jira] [Commented] (KAFKA-19519) Introduce a new config for group coordinator max record size
Chia-Ping Tsai (Jira)
[jira] [Updated] (KAFKA-19519) Introduce a new config for group coordinator max record size
Lan Ding (Jira)
[jira] [Updated] (KAFKA-19519) Introduce a new config for group coordinator max record size
Lan Ding (Jira)
[jira] [Updated] (KAFKA-19519) Introduce a new config for group coordinator max record size
Lan Ding (Jira)
[jira] [Updated] (KAFKA-19519) Introduce a new config for group coordinator max record size
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-19519) Introduce a new config for group coordinator max record size
Luke Chen (Jira)
[PR] MINOR: Remove unnecessary dependencies from coordinator-common (follow up to pr#20089) [kafka]
via GitHub
[PR] [DRAFT for 5.0] KAFKA-12281 cleanup deprecated exceptions [kafka]
via GitHub
Re: [PR] KAFKA-12281: cleanup deprecated exceptions [DRAFT for 5.0] [kafka]
via GitHub
Re: [PR] KAFKA-12281: cleanup deprecated exceptions [DRAFT for 5.0] [kafka]
via GitHub
[PR] KAFKA-12281 deprecate BrokerNotFoundException [kafka]
via GitHub
Re: [PR] KAFKA-12281 deprecate BrokerNotFoundException [kafka]
via GitHub
Re: [PR] KAFKA-12281 deprecate BrokerNotFoundException [kafka]
via GitHub
Re: [PR] MINOR: Run CI with Java 24 and update documentation (instead of 23) [kafka]
via GitHub
[jira] [Resolved] (KAFKA-19509) Improve error message when release version is wrong
TengYao Chi (Jira)
[PR] Delete NOTICE [kafka]
via GitHub
Re: [PR] Delete NOTICE [kafka]
via GitHub
Re: [PR] Delete NOTICE [kafka]
via GitHub
[PR] Update NOTICE [kafka]
via GitHub
Re: [PR] Update NOTICE [kafka]
via GitHub
[PR] Update wrapper.gradle [kafka]
via GitHub
Re: [PR] Update wrapper.gradle [kafka]
via GitHub
[PR] MINOR: [WIP] 40 ut [kafka]
via GitHub
[jira] [Assigned] (KAFKA-19517) LoadSummary#numBytes include the size of all records, but LoadSummary#numRecords only includes non-controller records
Logan Zhu (Jira)
[jira] [Assigned] (KAFKA-19518) Remove the usage of KafkaMetricsGroup(Class<?> klass)
Yu Chia Ma (Jira)
[jira] [Created] (KAFKA-19518) Remove the usage of KafkaMetricsGroup(Class<?> klass)
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-19517) LoadSummary#numBytes include the size of all records, but LoadSummary#numRecords only includes non-controller records
Chia-Ping Tsai (Jira)
[jira] [Assigned] (KAFKA-19511) Fix flaky test HandlingSourceTopicDeletionIntegrationTest.shouldThrowErrorAfterSourceTopicDeleted
travis (Jira)
[PR] MINOR: Revert "KAFKA-18913: Start state updater in task manager (#198… [kafka]
via GitHub
Re: [PR] MINOR: Revert "KAFKA-18913: Start state updater in task manager (#198… [kafka]
via GitHub
[jira] [Commented] (KAFKA-17206) Use v1 of LeaderChangeMessage when kraft.version is 1
Ksolves India Limited (Jira)
[jira] [Resolved] (KAFKA-19377) Update /streams/developer-guide/security.html for KIP-1071
Haozhong Ma (Jira)
[jira] [Resolved] (KAFKA-15300) Include remotelog size in complete log size and also add local log size and remote log size separately in kafka-log-dirs tool.
Kamal Chandraprakash (Jira)
[jira] [Updated] (KAFKA-18825) Fix the flaky EligibleLeaderReplicasIntegrationTest
Ksolves India Limited (Jira)
[jira] [Commented] (KAFKA-15300) Include remotelog size in complete log size and also add local log size and remote log size separately in kafka-log-dirs tool.
ally heev (Jira)
[jira] [Commented] (KAFKA-15300) Include remotelog size in complete log size and also add local log size and remote log size separately in kafka-log-dirs tool.
PoAn Yang (Jira)
[jira] [Assigned] (KAFKA-15300) Include remotelog size in complete log size and also add local log size and remote log size separately in kafka-log-dirs tool.
ally heev (Jira)
Re: [PR] MINOR: Simplify PartitionStates update logic by removing unnecessary grouping [kafka]
via GitHub
Re: [PR] KAFKA-18873: Fixed incorrect error message when exceeds 5 for transactional producers [kafka]
via GitHub
[PR] KAFKA-19509: Improve error message when release version is wrong [kafka]
via GitHub
Re: [PR] KAFKA-19509: Improve error message when release version is wrong [kafka]
via GitHub
Re: [PR] KAFKA-19509: Improve error message when release version is wrong [kafka]
via GitHub
Re: [PR] KAFKA-19509: Improve error message when release version is wrong [kafka]
via GitHub
Re: [PR] KAFKA-19509: Improve error message when release version is wrong [kafka]
via GitHub
Re: [PR] KAFKA-19509: Improve error message when release version is wrong [kafka]
via GitHub
Re: [PR] KAFKA-19509: Improve error message when release version is wrong [kafka]
via GitHub
[jira] [Assigned] (KAFKA-19509) Improve error message when release version is wrong
Lan Ding (Jira)
[jira] [Assigned] (KAFKA-14405) Log a warning when users attempt to set a config controlled by Streams
Matthias J. Sax (Jira)
[PR] KAFKA-19516: Added a request timeout of 120000ms to CreateTopics in ShareFetchAcknolwedgeRequestTest methods [kafka]
via GitHub
Re: [PR] KAFKA-19516: Added a request timeout of 120000ms to CreateTopics in ShareFetchAcknolwedgeRequestTest methods [kafka]
via GitHub
Re: [PR] KAFKA-19516: Added a request timeout of 120000ms to CreateTopics in ShareFetchAcknolwedgeRequestTest methods [kafka]
via GitHub
Re: [PR] KAFKA-19516: Added a request timeout of 120000ms to CreateTopics in ShareFetchAcknolwedgeRequestTest methods [kafka]
via GitHub
Re: [PR] KAFKA-19516: Added a request timeout of 120000ms to CreateTopics in ShareFetchAcknolwedgeRequestTest methods [kafka]
via GitHub
[PR] KAFKA-19511: Fix flaky test HandlingSourceTopicDeletionIntegrationTest.shouldThrowErrorAfterSourceTopicDeleted [kafka]
via GitHub
Re: [PR] KAFKA-19511: Fix flaky test HandlingSourceTopicDeletionIntegrationTest.shouldThrowErrorAfterSourceTopicDeleted [kafka]
via GitHub
Re: [PR] KAFKA-19511: Fix flaky test HandlingSourceTopicDeletionIntegrationTest.shouldThrowErrorAfterSourceTopicDeleted [kafka]
via GitHub
Re: [PR] KAFKA-19511: Fix flaky test HandlingSourceTopicDeletionIntegrationTest.shouldThrowErrorAfterSourceTopicDeleted [kafka]
via GitHub
[PR] KAFKA-19511: Fix flaky test HandlingSourceTopicDeletionIntegrationTest.shouldThrowErrorAfterSourceTopicDeleted [kafka]
via GitHub
Re: [PR] KAFKA-19511: Fix flaky test HandlingSourceTopicDeletionIntegrationTest.shouldThrowErrorAfterSourceTopicDeleted [kafka]
via GitHub
Re: [PR] KAFKA-19511: Fix flaky test HandlingSourceTopicDeletionIntegrationTest.shouldThrowErrorAfterSourceTopicDeleted [kafka]
via GitHub
Re: [PR] KAFKA-19511: Fix flaky test HandlingSourceTopicDeletionIntegrationTest.shouldThrowErrorAfterSourceTopicDeleted [kafka]
via GitHub
Re: [PR] KAFKA-19511: Fix flaky test HandlingSourceTopicDeletionIntegrationTest.shouldThrowErrorAfterSourceTopicDeleted [kafka]
via GitHub
[PR] MINOR: Declare inner helper classes as static [kafka]
via GitHub
Re: [PR] MINOR: Declare inner helper classes as static [kafka]
via GitHub
Re: [PR] MINOR: Declare inner RocksDBDualCFIterator class as static [kafka]
via GitHub
[jira] [Resolved] (KAFKA-19501) System tests should use 17-bullseye instead of 17-buster
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-19516) Resolve flakiness in ShareFetchAcknowledgeRequestTest
Chirag Wadhwa (Jira)
[PR] MINOR: Fix RemoteLogManager.getLeaderEpochEntries comment error [kafka]
via GitHub
Re: [PR] MINOR: Fix RemoteLogManager.getLeaderEpochEntries comment error [kafka]
via GitHub
Re: [PR] MINOR: Fix RemoteLogManager.getLeaderEpochEntries comment error [kafka]
via GitHub
Re: [PR] MINOR: Fix RemoteLogManager.getLeaderEpochEntries comment error [kafka]
via GitHub
[PR] MINOR: Cleanup Server Module [kafka]
via GitHub
[jira] [Assigned] (KAFKA-19427) The __consumer_offsets topic applies the broker configuration message.max.bytes, which may cause the coordinator broker to allocate too much memory and cause OOM
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-19427) The __consumer_offsets topic applies the broker configuration message.max.bytes, which may cause the coordinator broker to allocate too much memory and cause OOM
Chia-Ping Tsai (Jira)
[jira] [Comment Edited] (KAFKA-19427) The __consumer_offsets topic applies the broker configuration message.max.bytes, which may cause the coordinator broker to allocate too much memory and cause OOM
Chia-Ping Tsai (Jira)
[PR] MINOR : Handle error for client telemetry push (#19881) [kafka]
via GitHub
Re: [PR] Cherrypick "MINOR : Handle error for client telemetry push (#19881)" [kafka]
via GitHub
[jira] [Created] (KAFKA-19515) Align broker and controller "advertised.listeners" and "listeners" behaviour
Jira
[jira] [Updated] (KAFKA-19515) Align broker and controller "advertised.listeners" and "listeners" behaviour
Jira
[jira] [Updated] (KAFKA-19515) Align broker and controller "advertised.listeners" and "listeners" behaviour
Jira
[PR] KAFKA-19490: Remove usages of distutils in docker scripts (wip) [kafka]
via GitHub
[PR] MINOR: Remove duplicate renewTimePeriodOpt in DelegationTokenCommand validation [kafka]
via GitHub
[PR] Cherrypick "MINOR : Handle error for client telemetry push (#19881)" [kafka]
via GitHub
Re: [PR] Cherrypick "MINOR : Handle error for client telemetry push (#19881)" [kafka]
via GitHub
[PR] Cherrypick "MINOR : Handle error for client telemetry push (#19881)" [kafka]
via GitHub
[jira] [Commented] (KAFKA-12281) cleanup deprecated exceptions in org.apache.kafka.streams.errors.*
Rajani Karuturi (Jira)
[jira] [Commented] (KAFKA-12281) cleanup deprecated exceptions in org.apache.kafka.streams.errors.*
Matthias J. Sax (Jira)
[jira] [Commented] (KAFKA-12281) cleanup deprecated exceptions in org.apache.kafka.streams.errors.*
Rajani Karuturi (Jira)
[jira] [Commented] (KAFKA-12281) cleanup deprecated exceptions in org.apache.kafka.streams.errors.*
Matthias J. Sax (Jira)
[jira] [Commented] (KAFKA-12281) cleanup deprecated exceptions in org.apache.kafka.streams.errors.*
Rajani Karuturi (Jira)
[jira] [Commented] (KAFKA-12281) cleanup deprecated exceptions in org.apache.kafka.streams.errors.*
Rajani Karuturi (Jira)
[jira] [Commented] (KAFKA-14450) Rack-aware partition assignment for consumers (KIP-881)
Stanislav Kozlovski (Jira)
[jira] [Updated] (KAFKA-19514) Deprecate and remove Properties from public API
Jhen-Yung Hsu (Jira)
[jira] [Updated] (KAFKA-19514) Deprecate and remove Properties from public API
Jhen-Yung Hsu (Jira)
[jira] [Updated] (KAFKA-19514) Deprecate and remove Properties from public API
Jhen-Yung Hsu (Jira)
[jira] [Updated] (KAFKA-19514) Deprecate and remove Properties from public API
Kirk True (Jira)
[jira] [Updated] (KAFKA-19514) Deprecate and remove Properties from public API
Kirk True (Jira)
[jira] [Created] (KAFKA-19514) Deprecate and remove Properties from public API
Jhen-Yung Hsu (Jira)
[PR] Corrected the logger name in PersisterStateManagerHandler [kafka]
via GitHub
Re: [PR] Corrected the logger name in PersisterStateManagerHandler [kafka]
via GitHub
Re: [PR] KAFKA-19499: Corrected the logger name in PersisterStateManagerHandler [kafka]
via GitHub
[jira] [Updated] (KAFKA-12281) cleanup deprecated exceptions in org.apache.kafka.streams.errors.*
Rajani Karuturi (Jira)
[jira] [Updated] (KAFKA-12281) cleanup deprecated exceptions in org.apache.kafka.streams.errors.*
Rajani Karuturi (Jira)
[jira] [Created] (KAFKA-19513) Flaky test: AclControlManagerTest.testDeleteExceedsMaxRecords()
Apoorv Mittal (Jira)
Re: [PR] MINOR: fix docs references to missing features that are no longer missing [kafka]
via GitHub
[jira] [Resolved] (KAFKA-19305) Make ClientQuotaImage and TopicImage immutable
Chia-Ping Tsai (Jira)
Re: [PR] KAFKA-19305 Make ClientQuotaImage and TopicImage immutable [kafka]
via GitHub
[jira] [Updated] (KAFKA-19305) Make ClientQuotaImage and TopicImage immutable
Chia-Ping Tsai (Jira)
[PR] MINOR: Bump LATEST_PRODUCTION to 4.1IV1 and Use MV to enable ELR [kafka]
via GitHub
Re: [PR] MINOR: Bump LATEST_PRODUCTION to 4.1IV1 and Use MV to enable ELR [kafka]
via GitHub
[jira] [Commented] (KAFKA-16174) Flaky test: testDescribeQuorumStatusSuccessful – org.apache.kafka.tools.MetadataQuorumCommandTest
Jun Rao (Jira)
[jira] [Commented] (KAFKA-19481) Fix flaky test AuthorizerIntegrationTest.testConsumerGroupHeartbeatWithRegex()
Jun Rao (Jira)
[PR] KAFKA-19512 Add missing MVs in MetadataVersionTest [kafka]
via GitHub
Re: [PR] KAFKA-19512 Add missing MVs in MetadataVersionTest [kafka]
via GitHub
Re: [PR] KAFKA-19512 Add missing MVs in MetadataVersionTest [kafka]
via GitHub
[jira] [Assigned] (KAFKA-19512) add missing MVs in MetadataVersionTest
Dmitry Werner (Jira)
[jira] [Created] (KAFKA-19512) add missing MVs in MetadataVersionTest
Jun Rao (Jira)
[jira] [Updated] (KAFKA-19511) Fix flaky test HandlingSourceTopicDeletionIntegrationTest.shouldThrowErrorAfterSourceTopicDeleted
Lucy Liu (Jira)
[jira] [Updated] (KAFKA-19511) Fix flaky test HandlingSourceTopicDeletionIntegrationTest.shouldThrowErrorAfterSourceTopicDeleted
Lucy Liu (Jira)
[jira] [Updated] (KAFKA-19511) Fix flaky test HandlingSourceTopicDeletionIntegrationTest.shouldThrowErrorAfterSourceTopicDeleted
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-19511) Fix flaky test HandlingSourceTopicDeletionIntegrationTest.shouldThrowErrorAfterSourceTopicDeleted
Matthias J. Sax (Jira)
[jira] [Created] (KAFKA-19511) Fix flaky test HandlingSourceTopicDeletionIntegrationTest.shouldThrowErrorAfterSourceTopicDeleted
Lucy Liu (Jira)
[jira] [Assigned] (KAFKA-19506) Implement dynamic compression type selection and fallback for client telemetry
Kaushik Raina (Jira)
[PR] KAFKA-19478 [3/N]: Use heaps to discover the least loaded process [kafka]
via GitHub
[PR] MINOR: Replace long with long [kafka]
via GitHub
Re: [PR] MINOR: Replace long with long [kafka]
via GitHub
Re: [PR] MINOR: Replace Long with primitive long in offset-related methods [kafka]
via GitHub
Re: [PR] MINOR: Replace Long with primitive long in offset-related methods [kafka]
via GitHub
Re: [PR] MINOR: Replace Long with primitive long for CoordinatorPlayback [kafka]
via GitHub
[jira] [Commented] (KAFKA-16768) SocketServer leaks accepted SocketChannel instances due to race condition
Chang-Yu Huang (Jira)
Re: [PR] KAFKA-15910: New group coordinator needs to generate snapshots while loading [kafka]
via GitHub
Re: [PR] KAFKA-15910: New group coordinator needs to generate snapshots while loading [kafka]
via GitHub
[jira] [Assigned] (KAFKA-16768) SocketServer leaks accepted SocketChannel instances due to race condition
Chang-Yu Huang (Jira)
Re: [PR] KAFKA-17853: Fix termination issue in ConsoleConsumer and ConsoleShareConsumer [kafka]
via GitHub
Re: [PR] KAFKA-17853: Fix termination issue in ConsoleConsumer and ConsoleShareConsumer [kafka]
via GitHub
[jira] [Comment Edited] (KAFKA-19510) Kafka Streams does not always release lock when adding or removing threads multiple times
Lucas Brutschy (Jira)
[jira] [Commented] (KAFKA-19510) Kafka Streams does not always release lock when adding or removing threads multiple times
Lucas Brutschy (Jira)
[jira] [Created] (KAFKA-19510) Kafka Streams does not always release lock when adding or removing threads multiple times
Lucas Brutschy (Jira)
[jira] [Updated] (KAFKA-19510) Kafka Streams does not always release lock when adding or removing threads multiple times
Lucas Brutschy (Jira)
[jira] [Updated] (KAFKA-19510) Kafka Streams does not always release lock when adding or removing threads multiple times
Lucas Brutschy (Jira)
[jira] [Updated] (KAFKA-19510) Kafka Streams does not always release lock when adding or removing threads multiple times
Lucas Brutschy (Jira)
[jira] [Updated] (KAFKA-19510) Kafka Streams does not always release lock when adding or removing threads multiple times
Lucas Brutschy (Jira)
[jira] [Assigned] (KAFKA-19332) Fix flaky test : testAlterReadCommittedToReadUncommittedIsolationLevelWithReleaseAck and testAlterReadCommittedToReadUncommittedIsolationLevelWithRejectAck
Apoorv Mittal (Jira)
[jira] [Assigned] (KAFKA-19332) Fix flaky test : testAlterReadCommittedToReadUncommittedIsolationLevelWithReleaseAck and testAlterReadCommittedToReadUncommittedIsolationLevelWithRejectAck
Apoorv Mittal (Jira)
[jira] [Commented] (KAFKA-18220) Refactor AsyncConsumerMetrics so they are appropriate for share consumers
Andrew Schofield (Jira)
[jira] [Assigned] (KAFKA-18220) Refactor AsyncConsumerMetrics so they are appropriate for share consumers
Apoorv Mittal (Jira)
[jira] [Assigned] (KAFKA-19464) remove findNextFetchOffset.set(true) from acknowledge and release acquired records functionality
Apoorv Mittal (Jira)
[jira] [Commented] (KAFKA-19404) Connect's plugin.path documentation does not match behavior
Ksolves India Limited (Jira)
[jira] [Commented] (KAFKA-10825) Consolidate code between ZK and AlterISR for ISR updates
Ksolves India Limited (Jira)
[jira] [Commented] (KAFKA-19509) Improve error message when release version is wrong
Lan Ding (Jira)
[jira] [Commented] (KAFKA-19509) Improve error message when release version is wrong
Luke Chen (Jira)
[jira] [Comment Edited] (KAFKA-19479) at_least_once mode in Kafka Streams silently drops messages when the producer fails with MESSAGE_TOO_LARGE, violating delivery guarantees
Mihai Lucian (Jira)
[jira] [Created] (KAFKA-19509) Improve error message when release version is wrong
Luke Chen (Jira)
[jira] [Updated] (KAFKA-19508) Producer keeps reporting a NotLeaderOrFollowerException
mooner (Jira)
[jira] [Updated] (KAFKA-19508) Producer keeps reporting a NotLeaderOrFollowerException
mooner (Jira)
[jira] [Updated] (KAFKA-19508) Producer keeps reporting a NotLeaderOrFollowerException
mooner (Jira)
[jira] [Updated] (KAFKA-19508) Producer keeps reporting a NotLeaderOrFollowerException
mooner (Jira)
[jira] [Updated] (KAFKA-19508) Producer keeps reporting a NotLeaderOrFollowerException
mooner (Jira)
[jira] [Updated] (KAFKA-19508) Producer keeps reporting a NotLeaderOrFollowerException
mooner (Jira)
[jira] [Updated] (KAFKA-19508) Producer keeps reporting a NotLeaderOrFollowerException
Kirk True (Jira)
[jira] [Created] (KAFKA-19508) Producer keeps reporting a NotLeaderOrFollowerException
mooner (Jira)
[jira] [Assigned] (KAFKA-19507) Optimize Replica Assignment for Broker Load Balance in Uneven Rack Configurations
Jialun Peng (Jira)
[jira] [Created] (KAFKA-19507) Optimize Replica Assignment for Broker Load Balance in Uneven Rack Configurations
Jialun Peng (Jira)
[PR] MINOR: add a test for Protocol [kafka]
via GitHub
Re: [PR] MINOR: add a test for Protocol [kafka]
via GitHub
[jira] [Assigned] (KAFKA-19500) kafka-consumer-groups.sh should fail quickly if the partition leader is unavailable
kangning.li (Jira)
[jira] [Updated] (KAFKA-19506) Implement dynamic compression type selection and fallback for client telemetry
Kaushik Raina (Jira)
[jira] [Updated] (KAFKA-19506) Implement dynamic compression type selection and fallback for client telemetry
Kaushik Raina (Jira)
[PR] KAFKA-19500: `kafka-consumer-groups.sh` should fail quickly if the partition leader is unavailable [kafka]
via GitHub
Re: [PR] KAFKA-19500: `kafka-consumer-groups.sh` should fail quickly if the partition leader is unavailable [kafka]
via GitHub
Re: [PR] KAFKA-19500: `kafka-consumer-groups.sh` should fail quickly if the partition leader is unavailable [kafka]
via GitHub
Re: [PR] KAFKA-19500: `kafka-consumer-groups.sh` should fail quickly if the partition leader is unavailable [kafka]
via GitHub
Re: [PR] KAFKA-19500: `kafka-consumer-groups.sh` should fail quickly if the partition leader is unavailable [kafka]
via GitHub
Re: [PR] KAFKA-19500: `kafka-consumer-groups.sh` should fail quickly if the partition leader is unavailable [kafka]
via GitHub
Re: [PR] KAFKA-19500: `kafka-consumer-groups.sh` should fail quickly if the partition leader is unavailable [kafka]
via GitHub
Re: [PR] KAFKA-19500: `kafka-consumer-groups.sh` should fail quickly if the partition leader is unavailable [kafka]
via GitHub
Re: [PR] KAFKA-19500: `kafka-consumer-groups.sh` should fail quickly if the partition leader is unavailable [kafka]
via GitHub
Re: [PR] KAFKA-19500: `kafka-consumer-groups.sh` should fail quickly if the partition leader is unavailable [kafka]
via GitHub
[jira] [Created] (KAFKA-19506) Implement dynamic compression type selection and fallback for client telemetry
Kaushik Raina (Jira)
[jira] [Updated] (KAFKA-14915) Option to consume multiple partitions that have their data in remote storage for the target offsets.
Luke Chen (Jira)
[jira] [Assigned] (KAFKA-12380) Executor in Connect's Worker is not shut down when the worker is
Rajani Karuturi (Jira)
[jira] [Assigned] (KAFKA-12281) Deprecate org.apache.kafka.streams.errors.BrokerNotFoundException
Rajani Karuturi (Jira)
[jira] [Assigned] (KAFKA-19497) Topic replay code does not handle creation and deletion properly if it occurs in the same batch
zhu zhe (Jira)
[jira] [Commented] (KAFKA-14915) Option to consume multiple partitions that have their data in remote storage for the target offsets.
Kamal Chandraprakash (Jira)
Earlier messages