jira
Thread
Date
Earlier messages
Later messages
Messages by Thread
[jira] [Comment Edited] (KAFKA-18715) Unclean Recovery: Aggressive strategy
Tom Thornton (Jira)
[jira] [Commented] (KAFKA-18715) Unclean Recovery: Aggressive strategy
Tom Thornton (Jira)
[PR] Add unclean recovery aggressive & balanced strategies [kafka]
via GitHub
[jira] [Assigned] (KAFKA-21203) recovery could fail when a preallocated segment hits offset overflow
Nilesh Kumar (Jira)
[jira] [Commented] (KAFKA-21204) ListOffset may return -1 when offset is available
Jun Rao (Jira)
[jira] [Commented] (KAFKA-21204) ListOffset may return -1 when offset is available
Nilesh Kumar (Jira)
[jira] [Commented] (KAFKA-21204) ListOffset may return -1 when offset is available
Jun Rao (Jira)
[jira] [Created] (KAFKA-21204) ListOffset may return -1 when offset is available
Jun Rao (Jira)
[PR] KAFKA-16634: Fix flaky testFenceMultipleBrokers by increasing session timeout [kafka]
via GitHub
Re: [PR] KAFKA-16634: Fix flaky testFenceMultipleBrokers by increasing session timeout [kafka]
via GitHub
Re: [PR] KAFKA-16634: Fix flaky testFenceMultipleBrokers by increasing session timeout [kafka]
via GitHub
[jira] [Assigned] (KAFKA-16634) Flaky test - testFenceMultipleBrokers() – org.apache.kafka.controller.QuorumControllerTest
Rishi Kant Rana (Jira)
[jira] [Commented] (KAFKA-21203) recovery could fail when a preallocated segment hits offset overflow
Jun Rao (Jira)
[jira] [Commented] (KAFKA-21203) recovery could fail when a preallocated segment hits offset overflow
Nilesh Kumar (Jira)
[jira] [Commented] (KAFKA-21203) recovery could fail when a preallocated segment hits offset overflow
Jun Rao (Jira)
[jira] [Commented] (KAFKA-21203) recovery could fail when a preallocated segment hits offset overflow
Nilesh Kumar (Jira)
[jira] [Commented] (KAFKA-19785) Two Kafka brokers were not active in 3 node cluster setup
Rishi Kant Rana (Jira)
[jira] [Created] (KAFKA-21203) recovery could fail when a preallocated segment hits offset overflow
Jun Rao (Jira)
[jira] [Assigned] (KAFKA-19785) Two Kafka brokers were not active in 3 node cluster setup
Rishi Kant Rana (Jira)
Re: [PR] KAFKA-20841: Bound FileRecords.readInto to the size of the records [kafka]
via GitHub
[jira] [Resolved] (KAFKA-21134) Fix all hardcoded version links
Chia-Ping Tsai (Jira)
[jira] [Commented] (KAFKA-21134) Fix all hardcoded version links
ASF GitHub Bot (Jira)
[jira] [Assigned] (KAFKA-21202) listTransactionStates doesn't need to hold the lock so long
Ziyun Fu (Jira)
[jira] [Created] (KAFKA-21202) listTransactionStates doesn't need to hold the lock so long
Chia-Ping Tsai (Jira)
[PR] MINOR: Metadata cluster check enabled for admin [kafka]
via GitHub
Re: [PR] MINOR: Metadata cluster check enabled for admin [kafka]
via GitHub
[jira] [Updated] (KAFKA-21200) Make server-side rack-aware assignment opt-in (KIP-1379)
David Jacot (Jira)
[jira] [Created] (KAFKA-21200) Make server-side rack-aware assignment opt-in (KIP-1379)
David Jacot (Jira)
[jira] [Assigned] (KAFKA-21201) Store less classic member metadata in ConsumerGroupMemberMetadataValue
David Jacot (Jira)
[jira] [Created] (KAFKA-21201) Store less classic member metadata in ConsumerGroupMemberMetadataValue
Dongnuo Lyu (Jira)
[PR] KAFKA-21196: Release memory held by cancelled CoordinatorExecutorImpl tasks (4.3) [kafka]
via GitHub
[PR] KAFKA-21196: Release memory held by cancelled CoordinatorExecutorImpl tasks (4.4) [kafka]
via GitHub
Re: [PR] KAFKA-21196: Release memory held by cancelled CoordinatorExecutorImpl tasks (4.4) [kafka]
via GitHub
[jira] [Resolved] (KAFKA-21196) Release memory held by CoordinatorExecutorImpl tasks when cancelled
David Jacot (Jira)
[jira] [Resolved] (KAFKA-21199) The ProducerFailureHandlingTest#testCannotSendToInternalTopic test case is flaky
Maros Orsak (Jira)
[jira] [Assigned] (KAFKA-21199) The ProducerFailureHandlingTest#testCannotSendToInternalTopic test case is flaky
Andy Huang (Jira)
[jira] [Resolved] (KAFKA-18201) testGroupMetadataMessageFormatter fails for new consumer protocol
PoAn Yang (Jira)
[PR] MINOR: Add warm-up tests for coordinator failover, owner departure and multi-threaded members [kafka]
via GitHub
[jira] [Created] (KAFKA-21199) The ProducerFailureHandlingTest#testCannotSendToInternalTopic test case is flaky
Maros Orsak (Jira)
[PR] KAFKA-21196: Release memory held by cancelled CoordinatorExecutorImpl tasks [kafka]
via GitHub
Re: [PR] KAFKA-21196: Release memory held by cancelled CoordinatorExecutorImpl tasks [kafka]
via GitHub
[PR] KAFKA-20997: Improve KeyFactory loading (#23361) [kafka]
via GitHub
Re: [PR] KAFKA-20997: Improve KeyFactory loading (#23361) [kafka]
via GitHub
Re: [PR] KAFKA-20997: Improve KeyFactory loading (#23361) [kafka]
via GitHub
Re: [PR] KAFKA-20997: Improve KeyFactory loading (#23361) [kafka]
via GitHub
[PR] KAFKA-20855 Refactor Network Client [kafka]
via GitHub
Re: [PR] KAFKA-20855 Refactor Network Client [kafka]
via GitHub
Re: [PR] KAFKA-20855 Refactor Network Client [kafka]
via GitHub
Re: [PR] KAFKA-20855 Refactor Network Client [kafka]
via GitHub
Re: [PR] KAFKA-20855 Refactor Network Client [kafka]
via GitHub
Re: [PR] KAFKA-20855 Refactor Network Client [kafka]
via GitHub
Re: [PR] KAFKA-20855 Refactor Network Client [kafka]
via GitHub
[PR] Fix all hardcoded version links included images [kafka]
via GitHub
Re: [PR] KAFKA-21134 Fix all hardcoded version links included images [kafka]
via GitHub
Re: [PR] KAFKA-21134 Fix all hardcoded version links included images [kafka]
via GitHub
Re: [PR] KAFKA-21134 Fix all hardcoded version links included images [kafka]
via GitHub
Re: [PR] KAFKA-21134 Fix all hardcoded version links included images [kafka]
via GitHub
Re: [PR] KAFKA-21134 Fix all hardcoded version links included images [kafka]
via GitHub
Re: [PR] KAFKA-20976: Make max records per batch configurable [kafka]
via GitHub
[jira] [Updated] (KAFKA-20976) Make KRaft max partitions per request limit a config
Manikumar (Jira)
Re: [PR] MINOR: Only Apache Kafka allow to publish build scan [kafka]
via GitHub
Re: [PR] MINOR: Only Apache Kafka allow to publish build scan [kafka]
via GitHub
[jira] [Commented] (KAFKA-15138) Java kafka-clients compression dependencies should be optional
Joe DiPol (Jira)
[jira] [Created] (KAFKA-21198) Consider improving client-side visibility/logging for rejected Oauth token
Lianet Magrans (Jira)
[PR] MINOR: Add broker integration tests for topology-description plugin failure surfacing [kafka]
via GitHub
Re: [PR] MINOR: Add broker integration tests for topology-description plugin failure surfacing [kafka]
via GitHub
Re: [PR] MINOR: Add broker integration tests for topology-description plugin failure surfacing [kafka]
via GitHub
Re: [PR] MINOR: Add broker integration tests for topology-description plugin failure surfacing [kafka]
via GitHub
Re: [PR] MINOR: Add broker integration tests for topology-description plugin failure surfacing [kafka]
via GitHub
Re: [PR] MINOR: Add broker integration tests for topology-description plugin failure surfacing [kafka]
via GitHub
Re: [PR] MINOR: Add broker integration tests for topology-description plugin failure surfacing [kafka]
via GitHub
[PR] [MINOR] Add policy validation to CreatePartitions [kafka]
via GitHub
Re: [PR] MINOR: Add policy validation to CreatePartitions [kafka]
via GitHub
Re: [PR] MINOR: Add policy validation to CreatePartitions [kafka]
via GitHub
[PR] [MINOR] Add policy validation to CreatePartitions [kafka]
via GitHub
Re: [PR] MINOR: Add policy validation to CreatePartitions [kafka]
via GitHub
[jira] [Updated] (KAFKA-21196) Release memory held by CoordinatorExecutorImpl tasks when cancelled
Sean Quah (Jira)
[PR] KAFKA-20292 [12/N]: Add consumer and share GroupSpecBuilder.withAssignorOffload() [kafka]
via GitHub
Re: [PR] KAFKA-20292 [12/N]: Add consumer and share GroupSpecBuilder.withAssignorOffload() [kafka]
via GitHub
Re: [PR] KAFKA-20292 [12/N]: Add consumer and share GroupSpecBuilder.withAssignorOffload() [kafka]
via GitHub
[PR] KAFKA-20292 [13/N]: Add streams GroupSpecBuilder.withAssignorOffload() [kafka]
via GitHub
Re: [PR] KAFKA-20292 [13/N]: Add streams GroupSpecBuilder.withAssignorOffload() [kafka]
via GitHub
[jira] [Assigned] (KAFKA-21196) Release memory held by CoordinatorExecutorImpl tasks when cancelled
David Jacot (Jira)
[PR] KAFKA-21160 improve RequestHeader parsing on the broker [kafka]
via GitHub
[PR] MINOR: Add CLI test coverage for StreamsGroupTopologyDescriptionStatus.ERROR [kafka]
via GitHub
Re: [PR] MINOR: Add CLI test coverage for StreamsGroupTopologyDescriptionStatus.ERROR [kafka]
via GitHub
Re: [PR] MINOR: Add CLI test coverage for StreamsGroupTopologyDescriptionStatus.ERROR [kafka]
via GitHub
Re: [PR] MINOR: Add CLI test coverage for StreamsGroupTopologyDescriptionStatus.ERROR [kafka]
via GitHub
[PR] MINOR: Resilience improvements on leadership change [kafka]
via GitHub
[jira] [Commented] (KAFKA-21196) Release memory held by CoordinatorExecutorImpl tasks when cancelled
sanghyeok An (Jira)
[jira] [Commented] (KAFKA-21196) Release memory held by CoordinatorExecutorImpl tasks when cancelled
Sean Quah (Jira)
[jira] [Commented] (KAFKA-21196) Release memory held by CoordinatorExecutorImpl tasks when cancelled
sanghyeok An (Jira)
[PR] KAFKA-15853: [4/N] Move DynamicLogConfig and log config accessors to Java [kafka]
via GitHub
[PR] KAFKA-18905: Avoid out of order sequence errors from multiple in-flight batches [kafka]
via GitHub
Re: [PR] KAFKA-18905: Avoid out of order sequence errors from multiple in-flight batches [kafka]
via GitHub
Re: [PR] KAFKA-18905: Avoid out of order sequence errors from multiple in-flight batches [kafka]
via GitHub
Re: [PR] KAFKA-18905: Avoid out of order sequence errors from multiple in-flight batches [kafka]
via GitHub
Re: [PR] KAFKA-18905: Avoid out of order sequence errors from multiple in-flight batches [kafka]
via GitHub
Re: [PR] KAFKA-18905: Avoid out of order sequence errors from multiple in-flight batches [kafka]
via GitHub
[PR] [3/N] Move DynamicReplicationConfig to Java [kafka]
via GitHub
Re: [PR] KAFKA-15853: [3/N] Move DynamicReplicationConfig to Java [kafka]
via GitHub
Re: [PR] KAFKA-15853: [3/N] Move DynamicReplicationConfig to Java [kafka]
via GitHub
[PR] Remove MD5 and SHA-1 checksum files from our release process [kafka]
via GitHub
Re: [PR] KAFKA-21183: Remove MD5 and SHA-1 checksum files from our release process [kafka]
via GitHub
Re: [PR] KAFKA-21183: Remove MD5 and SHA-1 checksum files from our release process [kafka]
via GitHub
Re: [PR] KAFKA-21183: Remove MD5 and SHA-1 checksum files from our release process [kafka]
via GitHub
[PR] KAFKA-21197: Preserve original record headers in DLQ records. [kafka]
via GitHub
[PR] KSTREAMS-9353: Prove topology.description.push.enabled=false suppresses the update RPC end-to-end [kafka]
via GitHub
Re: [PR] MINOR: Prove topology.description.push.enabled=false suppresses the update RPC end-to-end [kafka]
via GitHub
Re: [PR] MINOR: Prove topology.description.push.enabled=false suppresses the update RPC end-to-end [kafka]
via GitHub
Re: [PR] MINOR: Prove topology.description.push.enabled=false suppresses the update RPC end-to-end [kafka]
via GitHub
[jira] [Created] (KAFKA-21197) Preserve original record headers if record copy enabled.
Sushant Mahajan (Jira)
[jira] [Commented] (KAFKA-21195) Use RE2/J in ClientMetricsConfigs
Apoorv Mittal (Jira)
[jira] [Commented] (KAFKA-21195) Use RE2/J in ClientMetricsConfigs
Chia-Ping Tsai (Jira)
[jira] [Commented] (KAFKA-21195) Use RE2/J in ClientMetricsConfigs
Apoorv Mittal (Jira)
[jira] [Assigned] (KAFKA-19070) Adding task number to the user provided client id (via consumer.override.client.id) to ensure each consumer has a unique client ID to avoid metric registration conflicts.
Andrew Schofield (Jira)
[jira] [Resolved] (KAFKA-20998) Add HA task assignor
Gavin Wang (Jira)
[PR] MINOR: Share group DLQ topic existence before config-only validation. [kafka]
via GitHub
Re: [PR] MINOR: Share group DLQ topic existence before config-only validation. [kafka]
via GitHub
Re: [PR] MINOR: Share group DLQ topic existence before config-only validation. [kafka]
via GitHub
Re: [PR] MINOR: Prioritise actionable share group DLQ topic validation errors. [kafka]
via GitHub
[jira] [Created] (KAFKA-21196) Release memory held by CoordinatorExecutorImpl tasks when cancelled
Sean Quah (Jira)
Re: [PR] KAFKA-18201: testGroupMetadataMessageFormatter fails for new consumer protocol [kafka]
via GitHub
Re: [PR] KAFKA-18201: testGroupMetadataMessageFormatter fails for new consumer protocol [kafka]
via GitHub
Re: [PR] KAFKA-18201: testGroupMetadataMessageFormatter fails for new consumer protocol [kafka]
via GitHub
Re: [PR] KAFKA-18201: testGroupMetadataMessageFormatter fails for new consumer protocol [kafka]
via GitHub
Re: [PR] KAFKA-18201: testGroupMetadataMessageFormatter fails for new consumer protocol [kafka]
via GitHub
Re: [PR] KAFKA-18201: testGroupMetadataMessageFormatter fails for new consumer protocol [kafka]
via GitHub
[jira] [Resolved] (KAFKA-21195) Use RE2/J in ClientMetricsConfigs
Apoorv Mittal (Jira)
[jira] [Assigned] (KAFKA-21195) Use RE2/J in ClientMetricsConfigs
Andy Huang (Jira)
[jira] [Created] (KAFKA-21194) Speed up the balanced task assignor and register it as a built-in assignor
Gavin Wang (Jira)
[jira] [Created] (KAFKA-21195) Use RE2/J in ClientMetricsConfigs
Chia-Ping Tsai (Jira)
[PR] KAFKA-21193: Speed up SuppressionIntegrationTest [kafka]
via GitHub
[jira] [Created] (KAFKA-21193) Speed up SuppressionIntegrationTest
Jira
[PR] KAFKA-21183: Remove MD5 and SHA-1 checksum files from release process [kafka]
via GitHub
Re: [PR] KAFKA-21183: Remove MD5 and SHA-1 checksum files from release process [kafka]
via GitHub
Re: [PR] KAFKA-21183: Remove MD5 and SHA-1 checksum files from release process [kafka]
via GitHub
[PR] KAFKA-18566: Document invalid UTF-8 offset metadata [kafka]
via GitHub
Re: [PR] Kafka-16355: Fix ConcurrentModificationException in evictWhile Method [kafka]
via GitHub
Re: [PR] Kafka-16355: Fix ConcurrentModificationException in evictWhile Method [kafka]
via GitHub
[PR] MINOR: Replace Collections factory methods with Java 9+ equivalents in server tests [kafka]
via GitHub
Re: [PR] MINOR: Replace Collections factory methods with Java 9+ equivalents in server tests [kafka]
via GitHub
[PR] KAFKA-20924: Use Request Header v3 for GetTelemetrySubscriptions and PushTelemetry v1 [kafka]
via GitHub
Re: [PR] KAFKA-20924: Use Request Header v3 for GetTelemetrySubscriptions and PushTelemetry v1 [kafka]
via GitHub
Re: [PR] KAFKA-20924: Use Request Header v3 for GetTelemetrySubscriptions and PushTelemetry v1 [kafka]
via GitHub
[jira] [Created] (KAFKA-21192) Skip deleting remote segments when the leader epoch cache does not cover the remote log range
Doyeon Kim (Jira)
[jira] [Updated] (KAFKA-21191) Rebuild the remote log aux state when a follower's leader epoch cache does not cover the remote log range
Doyeon Kim (Jira)
[jira] [Created] (KAFKA-21191) Rebuild the remote log aux state when a follower's leader epoch cache does not cover the remote log range
Doyeon Kim (Jira)
[jira] [Updated] (KAFKA-21102) Soften the validation for group coordinator tombstones
Sean Quah (Jira)
[jira] [Updated] (KAFKA-21102) Soften the validation for group coordinator tombstones
Gavin Wang (Jira)
[PR] KAFKA-21190: Skip remote aux state rebuild when the fetch start offset equals the log start offset [kafka]
via GitHub
Re: [PR] KAFKA-21190: Skip remote aux state rebuild when the fetch start offset equals the log start offset [kafka]
via GitHub
[jira] [Created] (KAFKA-21190) Empty follower fails to start when the KIP-1023 fetch start offset equals the leader's log start offset
Jax (Jira)
[PR] MINOR: Validate client quota values and cap throttle time to int range (3.9) [kafka]
via GitHub
Re: [PR] MINOR: Validate client quota values and cap throttle time to int range (3.9) [kafka]
via GitHub
[jira] [Created] (KAFKA-21188) Merging topics with different partition counts leaves some records unprocessed under the Streams Rebalance Protocol
sanghyeok An (Jira)
[jira] [Commented] (KAFKA-21184) Fix the race condition in share session
Aditya Kousik (Jira)
[jira] [Updated] (KAFKA-21186) Add test utilities for Streams custom assignors
sanghyeok An (Jira)
[jira] [Commented] (KAFKA-20803) Share-group persister: O(N^2) response demultiplexing in PersisterStateManager batched RPCs
Andrew Schofield (Jira)
Re: [PR] KAFKA-20803: Demultiplex batched persister responses once (WriteStateHandler) [kafka]
via GitHub
Re: [PR] KAFKA-20803: Demultiplex batched persister responses once (WriteStateHandler) [kafka]
via GitHub
[PR] MINOR: Replace try/fail/catch with assertThrows in remaining Streams tests [kafka]
via GitHub
Re: [PR] MINOR: Replace try/fail/catch with assertThrows in remaining Streams tests [kafka]
via GitHub
[jira] [Created] (KAFKA-21189) Classic members in a consumer group are loaded with the group level session timeout
Dongnuo Lyu (Jira)
[PR] MINOR: Accumulate renew ack checks from all nodes [kafka]
via GitHub
Re: [PR] MINOR: Accumulate renew ack checks from all nodes [kafka]
via GitHub
[jira] [Updated] (KAFKA-21188) Merging topics with different partition counts leaves some records unprocessed under the Streams Rebalance Protocol
sanghyeok An (Jira)
[jira] [Commented] (KAFKA-21188) Merging topics with different partition counts leaves some records unprocessed under the Streams Rebalance Protocol
sanghyeok An (Jira)
[jira] [Resolved] (KAFKA-21149) Speed up JoinGracePeriodDurabilityIntegrationTest
Ken Huang (Jira)
[jira] [Updated] (KAFKA-21161) Source-topic changelog store gets the task's last produced offset instead of its last consumed offset when the task writes to its own source topic
Bill Bejeck (Jira)
[jira] [Resolved] (KAFKA-21161) Source-topic changelog store gets the task's last produced offset instead of its last consumed offset when the task writes to its own source topic
Bill Bejeck (Jira)
[PR] MINOR: Validate client quota values and cap throttle time to int range (4.1) [kafka]
via GitHub
Re: [PR] MINOR: Validate client quota values and cap throttle time to int range (4.1) [kafka]
via GitHub
[PR] MINOR: Validate client quota values and cap throttle time to int range (4.2) [kafka]
via GitHub
Re: [PR] MINOR: Validate client quota values and cap throttle time to int range (4.2) [kafka]
via GitHub
[PR] MINOR: Validate client quota values and cap throttle time to int range (3.8) [kafka]
via GitHub
Re: [PR] MINOR: Validate client quota values and cap throttle time to int range (3.8) [kafka]
via GitHub
Re: [PR] KAFKA-20397 Avoid blocking on fetchBuffer when metadata error is pending [kafka]
via GitHub
Re: [PR] KAFKA-20397 Avoid blocking on fetchBuffer when metadata error is pending [kafka]
via GitHub
Re: [PR] KAFKA-20587: Wait for global store topic partitions in test setup [kafka]
via GitHub
[PR] MINOR: Validate client quota values and cap throttle time to int range (3.6) [kafka]
via GitHub
Re: [PR] MINOR: Validate client quota values and cap throttle time to int range (3.6) [kafka]
via GitHub
[PR] MINOR: Validate client quota values and cap throttle time to int range (3.7) [kafka]
via GitHub
Re: [PR] MINOR: Validate client quota values and cap throttle time to int range (3.7) [kafka]
via GitHub
[PR] MINOR: Validate client quota values and cap throttle time to int range (4.4) [kafka]
via GitHub
Re: [PR] MINOR: Validate client quota values and cap throttle time to int range (4.4) [kafka]
via GitHub
[PR] MINOR: Validate client quota values and cap throttle time to int range (4.0) [kafka]
via GitHub
Re: [PR] MINOR: Validate client quota values and cap throttle time to int range (4.0) [kafka]
via GitHub
[PR] MINOR: Validate client quota values and cap throttle time to int range (4.3) [kafka]
via GitHub
Re: [PR] MINOR: Validate client quota values and cap throttle time to int range (4.3) [kafka]
via GitHub
[jira] [Created] (KAFKA-21186) Add test utilities for Streams custom assignors
sanghyeok An (Jira)
[PR] KAFKA-21062: Handle BADVERSION on /migration writes [kafka]
via GitHub
[jira] [Resolved] (KAFKA-21041) ClientMetricsConfigs rejects match patterns whose regex contains an equals sign
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-21187) OffsetCommit returns UNKNOWN_MEMBER_ID instead of FENCED_INSTANCE_ID for replaced classic static members in a ConsumerGroup
sanghyeok An (Jira)
[jira] [Assigned] (KAFKA-21183) Remove MD5 and SHA-1 checksum files from our release process
Chang Chi Hsu (Jira)
[PR] KAFKA-20812 Move additional KRaftClusterTest tests to KafkaClusterTestKitTest [kafka]
via GitHub
[PR] KAFKA-21185: bump lz4 to 1.12.0 [kafka]
via GitHub
[jira] [Created] (KAFKA-21185) Update lz4 to 1.12.0
Jira
[PR] KAFKA-21182: includes pending revocation tasks to StreamsGroupDescribe API. [kafka]
via GitHub
[jira] [Created] (KAFKA-21184) Fix the race condition in share session
Chia-Ping Tsai (Jira)
Earlier messages
Later messages