jira  

Messages by Thread

• [jira] [Commented] (KAFKA-19048) Minimal Movement Replica Balancing algorithm for reassignment Mickael Maison (Jira)
• [jira] [Assigned] (KAFKA-14915) Option to consume multiple partitions that have their data in remote storage for the target offsets. Luke Chen (Jira)
• [jira] [Created] (KAFKA-19435) Optimize `kafka-consumer-groups.sh` to return the offset info of other partitions even when the leader of some partitions are missing kangning.li (Jira)
• [jira] [Updated] (KAFKA-18973) Review MetadataSchemaCheckerToolTest.testVerifyEvolutionGit requiring git project Mickael Maison (Jira)
• [jira] [Commented] (KAFKA-18031) Flaky PlaintextConsumerTest testCloseLeavesGroupOnInterrupt Mickael Maison (Jira)
• [jira] [Commented] (KAFKA-18857) Avoid authorization check in the group coordinator Mickael Maison (Jira)
• [jira] [Commented] (KAFKA-19307) Improve OAuthCompatibilityTool ergonomics Mickael Maison (Jira)
• [jira] [Updated] (KAFKA-19307) Improve OAuthCompatibilityTool ergonomics Mickael Maison (Jira)
• [jira] [Commented] (KAFKA-19265) Use snapshotting of remote log metedata topic that is used when a broker is restarted. Mickael Maison (Jira)
• [jira] [Updated] (KAFKA-18752) Fix the warning of no-operation caused by slf4j in building kafka Mickael Maison (Jira)
• [jira] [Commented] (KAFKA-18390) Use LinkedHashMap instead of Map in creating MetricName and SensorBuilder Mickael Maison (Jira)
• [jira] [Updated] (KAFKA-18390) Use LinkedHashMap instead of Map in creating MetricName and SensorBuilder Mickael Maison (Jira)
• [jira] [Commented] (KAFKA-19254) Add generic feature level metric Mickael Maison (Jira)
• [jira] [Commented] (KAFKA-17178) Update KTable.transformValues to new Processor API Mickael Maison (Jira)
• [jira] [Updated] (KAFKA-19254) Add generic feature level metric Mickael Maison (Jira)
• [jira] [Updated] (KAFKA-17573) Move KRaftMetadataCache to metadata module Mickael Maison (Jira)
• [jira] [Commented] (KAFKA-17573) Move KRaftMetadataCache to metadata module Mickael Maison (Jira)
• [jira] [Updated] (KAFKA-18031) Flaky PlaintextConsumerTest testCloseLeavesGroupOnInterrupt Mickael Maison (Jira)
• [jira] [Updated] (KAFKA-18509) Cleanup StateChangeLogger Mickael Maison (Jira)
• [jira] [Updated] (KAFKA-18087) Revert unnecessary integration testing of both consumer group protocols Mickael Maison (Jira)
• [jira] [Commented] (KAFKA-18477) remove usage of OffsetForLeaderEpochRequest in AbstractFetcherThread Mickael Maison (Jira)
• [jira] [Updated] (KAFKA-18582) Rename num_zk parameter in e2e Mickael Maison (Jira)
• [jira] [Commented] (KAFKA-18582) Rename num_zk parameter in e2e Mickael Maison (Jira)
• [jira] [Commented] (KAFKA-15402) Performance regression on close consumer after upgrading to 3.5.0 Mickael Maison (Jira)
• [jira] [Updated] (KAFKA-15402) Performance regression on close consumer after upgrading to 3.5.0 Mickael Maison (Jira)
• [jira] [Commented] (KAFKA-18185) Remove internal.leave.group.on.close flag Mickael Maison (Jira)
• [jira] [Updated] (KAFKA-18185) Remove internal.leave.group.on.close flag Mickael Maison (Jira)
• [jira] [Updated] (KAFKA-19048) Minimal Movement Replica Balancing algorithm for reassignment Mickael Maison (Jira)
  • [jira] [Updated] (KAFKA-19048) Minimal Movement Replica Balancing algorithm for reassignment Mickael Maison (Jira)
• [jira] [Commented] (KAFKA-18922) RequestContext#principalSerde should not be optional as it is now always present Mickael Maison (Jira)
• [jira] [Commented] (KAFKA-4566) Can't Symlink to Kafka bins Mickael Maison (Jira)
• [jira] [Commented] (KAFKA-18402) Optimise of comparison on org.apache.kafka.common.Uuid Mickael Maison (Jira)
• [jira] [Updated] (KAFKA-18402) Optimise of comparison on org.apache.kafka.common.Uuid Mickael Maison (Jira)
• [jira] [Resolved] (KAFKA-19428) IOException during writing max timestamp should not be ignored Lan Ding (Jira)
• [jira] [Commented] (KAFKA-18786) Enable returnning supported features from a specific broker PoAn Yang (Jira)
• Re: [PR] KAFKA-6333 java.awt.headless should not be on commandline [kafka] via GitHub
  • Re: [PR] KAFKA-6333 java.awt.headless should not be on commandline [kafka] via GitHub
  • Re: [PR] KAFKA-6333 java.awt.headless should not be on commandline [kafka] via GitHub
  • Re: [PR] KAFKA-6333 java.awt.headless should not be on commandline [kafka] via GitHub
• Re: [PR] MINOR: Write log differently according to the size of missingListenerPartitions [kafka] via GitHub
  • Re: [PR] MINOR: Write log differently according to the size of missingListenerPartitions [kafka] via GitHub
• Re: [PR] KAFKA-18842: add configurable max number of connectors [kafka] via GitHub
• Re: [PR] MINOR: Add doc for configuration parameters to keep the format consistent [kafka] via GitHub
• Re: [PR] MINOR: add SCRAM for security_rolling_upgrade [kafka] via GitHub
  • Re: [PR] MINOR: add SCRAM for security_rolling_upgrade [kafka] via GitHub
• Re: [PR] Feature/arch analysis [kafka] via GitHub
  • Re: [PR] Feature/arch analysis [kafka] via GitHub
• [PR] MINOR: Correcting exception codes in Share Partition [kafka] via GitHub
  • Re: [PR] MINOR: Correcting exception codes in Share Partition [kafka] via GitHub
• [jira] [Assigned] (KAFKA-19379) Update /streams/upgrade-guide for KIP-1071 Lucas Brutschy (Jira)
• [PR] KAFKA-19244: Fix flaky streams offsets reset integration test [kafka] via GitHub
  • Re: [PR] KAFKA-19244: Fix flaky streams offsets reset integration test [kafka] via GitHub
• [jira] [Resolved] (KAFKA-19407) OffsetsOutOfOrderException on followers due to the race condition in the leader Chia-Ping Tsai (Jira)
• [jira] [Updated] (KAFKA-19380) Update streams/developer-guide/app-reset-tool.html Lucas Brutschy (Jira)
• [PR] MINOR: Clean up in ReassignPartitionsCommandTest [kafka] via GitHub
  • Re: [PR] MINOR: Clean up in ReassignPartitionsCommandTest [kafka] via GitHub
  • Re: [PR] MINOR: Clean up in ReassignPartitionsCommandTest [kafka] via GitHub
• [jira] [Commented] (KAFKA-19433) Unify broker heartbeat RPC timeout and periodic resend timeout Jimmy Wang (Jira)
• [jira] [Assigned] (KAFKA-19432) Add an ERROR log message if broker.heartbeat.interval.ms is too large PoAn Yang (Jira)
• [jira] [Resolved] (KAFKA-19383) A duplicate topic record can be created when applying ClearElrRecord. Colin McCabe (Jira)
• [jira] [Updated] (KAFKA-19383) A duplicate topic record can be created when applying ClearElrRecord. Colin McCabe (Jira)
• [jira] [Resolved] (KAFKA-19294) Fix BrokerLifecycleManager RPC timeouts Colin McCabe (Jira)
• [jira] [Updated] (KAFKA-19294) Fix BrokerLifecycleManager RPC timeouts Colin McCabe (Jira)
  • [jira] [Updated] (KAFKA-19294) Fix BrokerLifecycleManager RPC timeouts Colin McCabe (Jira)
• [jira] [Updated] (KAFKA-19411) Delete ACLs records can exceed max records per user op Colin McCabe (Jira)
  • [jira] [Updated] (KAFKA-19411) Delete ACLs records can exceed max records per user op Colin McCabe (Jira)
• [jira] [Created] (KAFKA-19433) Unify broker heartbeat RPC timeout and periodic resend timeout Colin McCabe (Jira)
• [jira] [Updated] (KAFKA-19434) Move logic for for state store initiation to StreamThread handover Bill Bejeck (Jira)
• [PR] KAFKA-19383: Handle the deleted topics when applying ClearElrRecord (… [kafka] via GitHub
  • Re: [PR] KAFKA-19383: Handle the deleted topics when applying ClearElrRecord (… [kafka] via GitHub
  • [PR] KAFKA-19383: Handle the deleted topics when applying ClearElrRecord (… [kafka] via GitHub
  • Re: [PR] KAFKA-19383: Handle the deleted topics when applying ClearElrRecord (… [kafka] via GitHub
• [PR] MINOR: Fix response for consumer group describe with empty group id [kafka] via GitHub
  • Re: [PR] MINOR: Fix response for consumer group describe with empty group id [kafka] via GitHub
  • Re: [PR] MINOR: Fix response for consumer group describe with empty group id [kafka] via GitHub
  • Re: [PR] MINOR: Fix response for consumer group describe with empty group id [kafka] via GitHub
  • Re: [PR] MINOR: Fix response for consumer group describe with empty group id [kafka] via GitHub
  • Re: [PR] MINOR: Fix response for consumer group describe with empty group id [kafka] via GitHub
  • Re: [PR] MINOR: Fix response for consumer group describe with empty group id [kafka] via GitHub
• [PR] MINOR: Remove unused DescribeTopicPartitionResponse.prepareResponse function [kafka] via GitHub
  • Re: [PR] MINOR: Remove unused DescribeTopicPartitionResponse.prepareResponse function [kafka] via GitHub
  • Re: [PR] MINOR: Remove unused DescribeTopicPartitionResponse.prepareResponse function [kafka] via GitHub
  • Re: [PR] MINOR: Remove unused DescribeTopicPartitionResponse.prepareResponse function [kafka] via GitHub
• [jira] [Resolved] (KAFKA-18778) Fix the inconsistent lastest supported version in StorageTool.scala and FutureCommand Chia-Ping Tsai (Jira)
• [jira] [Assigned] (KAFKA-19433) Unify broker heartbeat RPC timeout and periodic resend timeout Jimmy Wang (Jira)
• [jira] [Resolved] (KAFKA-19411) Delete ACLs records can exceed max records per user op Colin McCabe (Jira)
• [jira] [Created] (KAFKA-19432) Add an ERROR log message if broker.heartbeat.interval.ms is too large Colin McCabe (Jira)
• Re: [PR] MINOR: Cleanup Connect Module (2/n) [kafka] via GitHub
  • Re: [PR] MINOR: Cleanup Connect Module (2/n) [kafka] via GitHub
  • Re: [PR] MINOR: Cleanup Connect Module (2/n) [kafka] via GitHub
• [PR] MINOR: Reject requests using unsupported features in KIP-1071 [kafka] via GitHub
  • Re: [PR] MINOR: Reject requests using unsupported features in KIP-1071 [kafka] via GitHub
  • Re: [PR] MINOR: Reject requests using unsupported features in KIP-1071 [kafka] via GitHub
  • Re: [PR] MINOR: Reject requests using unsupported features in KIP-1071 [kafka] via GitHub
  • Re: [PR] MINOR: Reject requests using unsupported features in KIP-1071 [kafka] via GitHub
  • Re: [PR] MINOR: Reject requests using unsupported features in KIP-1071 [kafka] via GitHub
  • Re: [PR] MINOR: Reject requests using unsupported features in KIP-1071 [kafka] via GitHub
• [jira] [Created] (KAFKA-19431) Stronger assignment consistency with subscription for consumer groups Sean Quah (Jira)
• [jira] [Assigned] (KAFKA-19380) Update streams/developer-guide/app-reset-tool.html Lucas Brutschy (Jira)
• Re: [PR] KAFKA-19371: When a broker restarts, it should not attempt to create the __remote_log_metadata topic if it already exists. [kafka] via GitHub
  • Re: [PR] KAFKA-19371: When a broker restarts, it should not attempt to create the __remote_log_metadata topic if it already exists. [kafka] via GitHub
  • Re: [PR] KAFKA-19371: When a broker restarts, it should not attempt to create the __remote_log_metadata topic if it already exists. [kafka] via GitHub
• [jira] [Commented] (KAFKA-16355) ConcurrentModificationException in InMemoryTimeOrderedKeyValueBuffer.evictWhile Ksolves India Limited (Jira)
  • [jira] [Commented] (KAFKA-16355) ConcurrentModificationException in InMemoryTimeOrderedKeyValueBuffer.evictWhile Mickael Maison (Jira)
  • [jira] [Commented] (KAFKA-16355) ConcurrentModificationException in InMemoryTimeOrderedKeyValueBuffer.evictWhile Matthias J. Sax (Jira)
• [jira] [Comment Edited] (KAFKA-19427) Kafka 4.0 may have a memory leak, causing an OOM exception RivenSun (Jira)
  • [jira] [Comment Edited] (KAFKA-19427) Kafka 4.0 may have a memory leak, causing an OOM exception David Jacot (Jira)
  • [jira] [Comment Edited] (KAFKA-19427) Kafka 4.0 may have a memory leak, causing an OOM exception RivenSun (Jira)
  • [jira] [Comment Edited] (KAFKA-19427) Kafka 4.0 may have a memory leak, causing an OOM exception RivenSun (Jira)
  • [jira] [Comment Edited] (KAFKA-19427) Kafka 4.0 may have a memory leak, causing an OOM exception RivenSun (Jira)
  • [jira] [Comment Edited] (KAFKA-19427) Kafka 4.0 may have a memory leak, causing an OOM exception RivenSun (Jira)
  • [jira] [Comment Edited] (KAFKA-19427) Kafka 4.0 may have a memory leak, causing an OOM exception David Jacot (Jira)
• [jira] (KAFKA-17136) Added Documentation for Shell Methods Ksolves India Limited (Jira)
• [PR] KAFKA-18656: Backport KAFKA-18597 to 4.0 [kafka] via GitHub
  • Re: [PR] KAFKA-18656: Backport KAFKA-18597 to 4.0 [kafka] via GitHub
  • Re: [PR] KAFKA-18656: Backport KAFKA-18597 to 4.0 [kafka] via GitHub
• [jira] [Assigned] (KAFKA-18656) Backport KAFKA-18597 to 4.0 Logan Zhu (Jira)
• [PR] KAFKA-19152: Add top-level documentation for OAuth flows [kafka] via GitHub
  • Re: [PR] KAFKA-19152: Add top-level documentation for OAuth flows [kafka] via GitHub
  • Re: [PR] KAFKA-19152: Add top-level documentation for OAuth flows [kafka] via GitHub
• [jira] [Assigned] (KAFKA-18692) Consider to unify KStreamImpl "repartitionRequired" with GraphNode "keyChangingOperation" Matthias J. Sax (Jira)
• [PR] DRAFT: testDelayedTxnOffsetCommitWithBumpedEpochIsRejected [kafka] via GitHub
  • Re: [PR] MINOR: testDelayedTxnOffsetCommitWithBumpedEpochIsRejected [kafka] via GitHub
  • Re: [PR] MINOR: Add tests on TxnOffsetCommit and EndTxnMarker protection against invalid producer epoch when TV2 is used [kafka] via GitHub
  • Re: [PR] MINOR: Add tests on TxnOffsetCommit and EndTxnMarker protection against invalid producer epoch when TV2 is used [kafka] via GitHub
• [jira] [Commented] (KAFKA-19371) When a broker restarts, it should not attempt to create the __remote_log_metadata topic if it already exists. fujian (Jira)
• [jira] [Commented] (KAFKA-19425) local segment on disk never deleted forever when remote storage initial failed fujian (Jira)
  • [jira] [Commented] (KAFKA-19425) local segment on disk never deleted forever when remote storage initial failed PoAn Yang (Jira)
• Re: [PR] KAFKA-18066: Fix mismatched StreamThread ID in log messages [kafka] via GitHub
• [jira] [Created] (KAFKA-19430) Don't fail on RecordCorruptedException Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-19367) InitProducerId with TV2 double-increments epoch if ongoing transaction is aborted Justine Olshan (Jira)
• [PR] MINOR: Correcting client error for fenced share partition [kafka] via GitHub
  • Re: [PR] MINOR: Correcting client error for fenced share partition [kafka] via GitHub
• Re: [PR] KAFKA-19282: Update quotaTypesEnabled on quota removal in ClientQuotaManager [kafka] via GitHub
  • Re: [PR] KAFKA-19282: Update quotaTypesEnabled on quota removal in ClientQuotaManager [kafka] via GitHub
  • Re: [PR] KAFKA-19282: Update quotaTypesEnabled on quota removal in ClientQuotaManager [kafka] via GitHub
  • Re: [PR] KAFKA-19282: Update quotaTypesEnabled on quota removal in ClientQuotaManager [kafka] via GitHub
  • Re: [PR] KAFKA-19282: Update quotaTypesEnabled on quota removal in ClientQuotaManager [kafka] via GitHub
  • Re: [PR] KAFKA-19282: Update quotaTypesEnabled on quota removal in ClientQuotaManager [kafka] via GitHub
  • Re: [PR] KAFKA-19282: Update quotaTypesEnabled on quota removal in ClientQuotaManager [kafka] via GitHub
• [jira] [Commented] (KAFKA-18656) Backport KAFKA-18597 to 4.0 Abhi (Jira)
  • [jira] [Commented] (KAFKA-18656) Backport KAFKA-18597 to 4.0 Chia-Ping Tsai (Jira)
• [jira] [Assigned] (KAFKA-19398) Error getting oldest-iterator-open-since-ms causes NPE in micrometer Matthias J. Sax (Jira)
• [PR] KAFKA-19398: (De)Register oldest-iterator-open-since-ms metric dynamically [kafka] via GitHub
  • Re: [PR] KAFKA-19398: (De)Register oldest-iterator-open-since-ms metric dynamically [kafka] via GitHub
  • Re: [PR] KAFKA-19398: (De)Register oldest-iterator-open-since-ms metric dynamically [kafka] via GitHub
  • Re: [PR] KAFKA-19398: (De)Register oldest-iterator-open-since-ms metric dynamically [kafka] via GitHub
  • Re: [PR] KAFKA-19398: (De)Register oldest-iterator-open-since-ms metric dynamically [kafka] via GitHub
  • Re: [PR] KAFKA-19398: (De)Register oldest-iterator-open-since-ms metric dynamically [kafka] via GitHub
  • Re: [PR] KAFKA-19398: (De)Register oldest-iterator-open-since-ms metric dynamically [kafka] via GitHub
  • Re: [PR] KAFKA-19398: (De)Register oldest-iterator-open-since-ms metric dynamically [kafka] via GitHub
  • Re: [PR] KAFKA-19398: (De)Register oldest-iterator-open-since-ms metric dynamically [kafka] via GitHub
  • Re: [PR] KAFKA-19398: (De)Register oldest-iterator-open-since-ms metric dynamically [kafka] via GitHub
• [PR] KAFKA-19254: Add generic feature level metrics [kafka] via GitHub
  • Re: [PR] KAFKA-19254: Add generic feature level metrics [kafka] via GitHub
  • Re: [PR] KAFKA-19254: Add generic feature level metrics [kafka] via GitHub
  • Re: [PR] KAFKA-19254: Add generic feature level metrics [kafka] via GitHub
  • Re: [PR] KAFKA-19254: Add generic feature level metrics [kafka] via GitHub
  • Re: [PR] KAFKA-19254: Add generic feature level metrics [kafka] via GitHub
  • Re: [PR] KAFKA-19254: Add generic feature level metrics [kafka] via GitHub
  • Re: [PR] KAFKA-19254: Add generic feature level metrics [kafka] via GitHub
  • Re: [PR] KAFKA-19254: Add generic feature level metrics [kafka] via GitHub
  • Re: [PR] KAFKA-19254: Add generic feature level metrics [kafka] via GitHub
  • Re: [PR] KAFKA-19254: Add generic feature level metrics [kafka] via GitHub
  • Re: [PR] KAFKA-19254: Add generic feature level metrics [kafka] via GitHub
  • Re: [PR] KAFKA-19254: Add generic feature level metrics [kafka] via GitHub
  • Re: [PR] KAFKA-19254: Add generic feature level metrics [kafka] via GitHub
  • Re: [PR] KAFKA-19254: Add generic feature level metrics [kafka] via GitHub
  • Re: [PR] KAFKA-19254: Add generic feature level metrics [kafka] via GitHub
  • Re: [PR] KAFKA-19254: Add generic feature level metrics [kafka] via GitHub
  • Re: [PR] KAFKA-19254: Add generic feature level metrics [kafka] via GitHub
  • Re: [PR] KAFKA-19254: Add generic feature level metrics [kafka] via GitHub
  • Re: [PR] KAFKA-19254: Add generic feature level metrics [kafka] via GitHub
  • Re: [PR] KAFKA-19254: Add generic feature level metrics [kafka] via GitHub
  • Re: [PR] KAFKA-19254: Add generic feature level metrics [kafka] via GitHub
  • Re: [PR] KAFKA-19254: Add generic feature level metrics [kafka] via GitHub
  • Re: [PR] KAFKA-19254: Add generic feature level metrics [kafka] via GitHub
  • Re: [PR] KAFKA-19254: Add generic feature level metrics [kafka] via GitHub
  • Re: [PR] KAFKA-19254: Add generic feature level metrics [kafka] via GitHub
  • Re: [PR] KAFKA-19254: Add generic feature level metrics [kafka] via GitHub
  • Re: [PR] KAFKA-19254: Add generic feature level metrics [kafka] via GitHub
  • Re: [PR] KAFKA-19254: Add generic feature level metrics [kafka] via GitHub
  • Re: [PR] KAFKA-19254: Add generic feature level metrics [kafka] via GitHub
• [PR] MINOR: Change exceptions for few error codes in SharePartition. [kafka] via GitHub
  • Re: [PR] MINOR: Change exceptions for few error codes in SharePartition. [kafka] via GitHub
• Re: [PR] KAFKA-12679: Handle lock exceptions in state updater [kafka] via GitHub
  • Re: [PR] KAFKA-12679: Handle lock exceptions in state updater [kafka] via GitHub
  • Re: [PR] KAFKA-12679: Handle lock exceptions in state updater [kafka] via GitHub
  • Re: [PR] KAFKA-12679: Handle lock exceptions in state updater [kafka] via GitHub
  • Re: [PR] KAFKA-12679: Handle lock exceptions in state updater [kafka] via GitHub
  • Re: [PR] KAFKA-12679: Handle lock exceptions in state updater [kafka] via GitHub
• [PR] KAFKA-19429: Deflake streams_smoke_test [kafka] via GitHub
  • Re: [PR] KAFKA-19429: Deflake streams_smoke_test [kafka] via GitHub
  • Re: [PR] KAFKA-19429: Deflake streams_smoke_test [kafka] via GitHub
  • Re: [PR] KAFKA-19429: Deflake streams_smoke_test [kafka] via GitHub
  • Re: [PR] KAFKA-19429: Deflake streams_smoke_test [kafka] via GitHub
• [jira] [Updated] (KAFKA-19429) Deflake streams_smoke_test Lucas Brutschy (Jira)
  • [jira] [Updated] (KAFKA-19429) Deflake streams_smoke_test Matthias J. Sax (Jira)
• [jira] [Created] (KAFKA-19429) Deflake streams_smoke_test Lucas Brutschy (Jira)
• [jira] [Commented] (KAFKA-19396) Use batched version of offset fetch request in new GroupCoordinator interface Kuan Po Tseng (Jira)

• Earlier messages
• Later messages