[jira] [Updated] (KAFKA-19449) Unexpected UNREVOKED_PARTITIONS to UNRELEASED_PARTITIONS transition in consumer member reconciliation

2025-06-30 Thread Sean Quah (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sean Quah updated KAFKA-19449: -- Description: We transition to `UNRELEASED_PARTITIONS` when advancing to a new target assignment and p

[jira] [Created] (KAFKA-19449) Unexpected UNREVOKED_PARTITIONS to UNRELEASED_PARTITIONS transition in consumer member reconciliation

2025-06-30 Thread Sean Quah (Jira)
Sean Quah created KAFKA-19449: - Summary: Unexpected UNREVOKED_PARTITIONS to UNRELEASED_PARTITIONS transition in consumer member reconciliation Key: KAFKA-19449 URL: https://issues.apache.org/jira/browse/KAFKA-19449

[jira] [Updated] (KAFKA-19431) Stronger assignment consistency with subscription for consumer groups

2025-06-29 Thread Sean Quah (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sean Quah updated KAFKA-19431: -- Description: Currently, consumer group assignments are eventually consistent with subscriptions: when

[jira] [Created] (KAFKA-19445) Group coordinator and share coordinator runtime metrics are aliased

2025-06-27 Thread Sean Quah (Jira)
Sean Quah created KAFKA-19445: - Summary: Group coordinator and share coordinator runtime metrics are aliased Key: KAFKA-19445 URL: https://issues.apache.org/jira/browse/KAFKA-19445 Project: Kafka

[jira] [Created] (KAFKA-19431) Stronger assignment consistency with subscription for consumer groups

2025-06-24 Thread Sean Quah (Jira)
Sean Quah created KAFKA-19431: - Summary: Stronger assignment consistency with subscription for consumer groups Key: KAFKA-19431 URL: https://issues.apache.org/jira/browse/KAFKA-19431 Project: Kafka

[jira] [Commented] (KAFKA-19427) Kafka 4.0 may have a memory leak, causing an OOM exception

2025-06-23 Thread Sean Quah (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17985627#comment-17985627 ] Sean Quah commented on KAFKA-19427: --- [~RivenSun] to help diagnose the issue, could you

[jira] [Updated] (KAFKA-19424) FindCoordinator inconsistent across brokers when __consumer_offsets partition count is increased

2025-06-20 Thread Sean Quah (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sean Quah updated KAFKA-19424: -- Description: {{GroupCoordinatorService}} captures the number of partitions of {{\_\_consumer_offsets}

[jira] [Created] (KAFKA-19424) FindCoordinator inconsistent across brokers when __consumer_offsets partition count is increased

2025-06-20 Thread Sean Quah (Jira)
Sean Quah created KAFKA-19424: - Summary: FindCoordinator inconsistent across brokers when __consumer_offsets partition count is increased Key: KAFKA-19424 URL: https://issues.apache.org/jira/browse/KAFKA-19424

[jira] [Created] (KAFKA-19417) Clear static member assignment on join with different subscription

2025-06-18 Thread Sean Quah (Jira)
Sean Quah created KAFKA-19417: - Summary: Clear static member assignment on join with different subscription Key: KAFKA-19417 URL: https://issues.apache.org/jira/browse/KAFKA-19417 Project: Kafka

[jira] [Updated] (KAFKA-19405) Assignor stickiness should keep owned partitions instead of partitions waiting to be revoked by another member

2025-06-12 Thread Sean Quah (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sean Quah updated KAFKA-19405: -- Description: Consider a new group with members joining. Each member is subscribed to the same topic.

[jira] [Created] (KAFKA-19405) Assignor stickiness should keep owned partitions instead of partitions waiting to be revoked by another member

2025-06-12 Thread Sean Quah (Jira)
Sean Quah created KAFKA-19405: - Summary: Assignor stickiness should keep owned partitions instead of partitions waiting to be revoked by another member Key: KAFKA-19405 URL: https://issues.apache.org/jira/browse/KAFK

[jira] [Commented] (KAFKA-18961) Consider time-based refresh for server-side RE2J regex

2025-05-12 Thread Sean Quah (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17951026#comment-17951026 ] Sean Quah commented on KAFKA-18961: --- It looks like the metadata image mechanism also l

[jira] [Created] (KAFKA-19164) New group coordinator won't delete groups with previously pending transactional offsets that were deleted

2025-04-16 Thread Sean Quah (Jira)
Sean Quah created KAFKA-19164: - Summary: New group coordinator won't delete groups with previously pending transactional offsets that were deleted Key: KAFKA-19164 URL: https://issues.apache.org/jira/browse/KAFKA-1916

[jira] [Updated] (KAFKA-19163) New group coordinator can incorrectly delete groups with pending transactional offsets

2025-04-16 Thread Sean Quah (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sean Quah updated KAFKA-19163: -- Description: When a group has pending transactional offsets and no committed offsets, the group coord

[jira] [Updated] (KAFKA-19163) New group coordinator can incorrectly delete groups with pending transactional offsets

2025-04-16 Thread Sean Quah (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sean Quah updated KAFKA-19163: -- Description: When a group has pending transactional offsets and no committed offsets, the group coord

[jira] [Created] (KAFKA-19163) New group coordinator can incorrectly delete groups with pending transactional offsets

2025-04-16 Thread Sean Quah (Jira)
Sean Quah created KAFKA-19163: - Summary: New group coordinator can incorrectly delete groups with pending transactional offsets Key: KAFKA-19163 URL: https://issues.apache.org/jira/browse/KAFKA-19163 Proj

[jira] [Created] (KAFKA-19160) Fetching stable offsets is very slow with a large number of partition and open transactions

2025-04-16 Thread Sean Quah (Jira)
Sean Quah created KAFKA-19160: - Summary: Fetching stable offsets is very slow with a large number of partition and open transactions Key: KAFKA-19160 URL: https://issues.apache.org/jira/browse/KAFKA-19160

[jira] [Created] (KAFKA-19025) Reuse buffers for LZ4 compression

2025-04-05 Thread Sean Quah (Jira)
Sean Quah created KAFKA-19025: - Summary: Reuse buffers for LZ4 compression Key: KAFKA-19025 URL: https://issues.apache.org/jira/browse/KAFKA-19025 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-19064) More exception handling for group coordinator events

2025-03-31 Thread Sean Quah (Jira)
Sean Quah created KAFKA-19064: - Summary: More exception handling for group coordinator events Key: KAFKA-19064 URL: https://issues.apache.org/jira/browse/KAFKA-19064 Project: Kafka Issue Type: Im

[jira] [Created] (KAFKA-19023) Snapshottable timers in the coordinator runtime

2025-03-24 Thread Sean Quah (Jira)
Sean Quah created KAFKA-19023: - Summary: Snapshottable timers in the coordinator runtime Key: KAFKA-19023 URL: https://issues.apache.org/jira/browse/KAFKA-19023 Project: Kafka Issue Type: Improve

[jira] [Resolved] (KAFKA-19025) Reuse buffers for LZ4 compression

2025-03-21 Thread Sean Quah (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sean Quah resolved KAFKA-19025. --- Resolution: Won't Do > Reuse buffers for LZ4 compression > - > >

[jira] [Updated] (KAFKA-18905) Avoid out of order sequence errors from multiple in-flight batches

2025-02-28 Thread Sean Quah (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sean Quah updated KAFKA-18905: -- Description: Consider a similar setup to KAFKA-9199: The broker attempts to cache the state of the la

[jira] [Updated] (KAFKA-18905) Avoid out of order sequence errors from multiple in-flight batches

2025-02-28 Thread Sean Quah (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sean Quah updated KAFKA-18905: -- Description: Consider a similar setup to KAFKA-9199: The broker attempts to cache the state of the la

[jira] [Created] (KAFKA-18905) Avoid out of order sequence errors from multiple in-flight batches

2025-02-28 Thread Sean Quah (Jira)
Sean Quah created KAFKA-18905: - Summary: Avoid out of order sequence errors from multiple in-flight batches Key: KAFKA-18905 URL: https://issues.apache.org/jira/browse/KAFKA-18905 Project: Kafka

[jira] [Updated] (KAFKA-18807) Group coordinator under-reports thread idle time

2025-02-18 Thread Sean Quah (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sean Quah updated KAFKA-18807: -- Description: When events arrive at the event processor with less than group.coordinator.threads ms be

[jira] [Updated] (KAFKA-18807) Group coordinator under-reports thread idle time

2025-02-18 Thread Sean Quah (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sean Quah updated KAFKA-18807: -- Description: When events arrive at the event processor with less than 1000/group.coordinator.threads

[jira] [Created] (KAFKA-18807) Group coordinator under-reports thread idle time

2025-02-16 Thread Sean Quah (Jira)
Sean Quah created KAFKA-18807: - Summary: Group coordinator under-reports thread idle time Key: KAFKA-18807 URL: https://issues.apache.org/jira/browse/KAFKA-18807 Project: Kafka Issue Type: Bug

[jira] [Assigned] (KAFKA-7691) Encypt-then-MAC Delegation token metadata

2025-02-01 Thread Sean Quah (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sean Quah reassigned KAFKA-7691: Assignee: Sean Quah (was: Attila Sasvári) > Encypt-then-MAC Delegation token metadata > -

[jira] [Assigned] (KAFKA-7691) Encypt-then-MAC Delegation token metadata

2025-02-01 Thread Sean Quah (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sean Quah reassigned KAFKA-7691: Assignee: Attila Sasvári (was: Sean Quah) > Encypt-then-MAC Delegation token metadata > -

[jira] [Created] (KAFKA-18688) Uniform homogeneous assignment is not always stable

2025-01-31 Thread Sean Quah (Jira)
Sean Quah created KAFKA-18688: - Summary: Uniform homogeneous assignment is not always stable Key: KAFKA-18688 URL: https://issues.apache.org/jira/browse/KAFKA-18688 Project: Kafka Issue Type: Bug

[jira] [Assigned] (KAFKA-18688) Uniform homogeneous assignment is not always stable

2025-01-31 Thread Sean Quah (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sean Quah reassigned KAFKA-18688: - Assignee: Sean Quah > Uniform homogeneous assignment is not always stable > ---

[jira] [Updated] (KAFKA-18687) New group coordinator triggers assignment recalculation on consumer group upgrade due to static member replacement

2025-01-31 Thread Sean Quah (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sean Quah updated KAFKA-18687: -- Description: When a consumer protocol static member replaces an existing member in a classic group, i

[jira] [Assigned] (KAFKA-18687) New group coordinator triggers assignment recalculation on consumer group upgrade due to static member replacement

2025-01-31 Thread Sean Quah (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sean Quah reassigned KAFKA-18687: - Assignee: Dongnuo Lyu > New group coordinator triggers assignment recalculation on consumer gro

[jira] [Updated] (KAFKA-18687) New group coordinator triggers assignment recalculation on consumer group upgrade due to static member replacement

2025-01-31 Thread Sean Quah (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sean Quah updated KAFKA-18687: -- Component/s: group-coordinator > New group coordinator triggers assignment recalculation on consumer g

[jira] [Created] (KAFKA-18687) New group coordinator triggers assignment recalculation on consumer group upgrade due to static member replacement

2025-01-31 Thread Sean Quah (Jira)
Sean Quah created KAFKA-18687: - Summary: New group coordinator triggers assignment recalculation on consumer group upgrade due to static member replacement Key: KAFKA-18687 URL: https://issues.apache.org/jira/browse/K

[jira] [Created] (KAFKA-18484) More robust exception handling for new group coordinator unload

2025-01-12 Thread Sean Quah (Jira)
Sean Quah created KAFKA-18484: - Summary: More robust exception handling for new group coordinator unload Key: KAFKA-18484 URL: https://issues.apache.org/jira/browse/KAFKA-18484 Project: Kafka Is

[jira] [Updated] (KAFKA-18199) Incorrect size calculation for ConsumerGroupMemberMetadataValue.classicMemberMetadata

2024-12-10 Thread Sean Quah (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sean Quah updated KAFKA-18199: -- Description: The code generated for {{write}} looks like: {code:java} _writable.writeUnsignedVarint(0)

[jira] [Updated] (KAFKA-18199) Incorrect size calculation for ConsumerGroupMemberMetadataValue.classicMemberMetadata

2024-12-10 Thread Sean Quah (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sean Quah updated KAFKA-18199: -- Description: The code generated for {{write}} looks like: {code:java} _writable.writeUnsignedVarint(0)

[jira] [Updated] (KAFKA-18199) Incorrect size calculation for ConsumerGroupMemberMetadataValue.classicMemberMetadata

2024-12-10 Thread Sean Quah (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sean Quah updated KAFKA-18199: -- Description: The code generated for {{write}} looks like: {code:java} _writable.writeUnsignedVarint(0)

[jira] [Created] (KAFKA-18200) New coordinator can flush an empty batch if append fails

2024-12-10 Thread Sean Quah (Jira)
Sean Quah created KAFKA-18200: - Summary: New coordinator can flush an empty batch if append fails Key: KAFKA-18200 URL: https://issues.apache.org/jira/browse/KAFKA-18200 Project: Kafka Issue Type

[jira] [Created] (KAFKA-18199) Incorrect size calculation for ConsumerGroupMemberMetadataValue.classicMemberMetadata

2024-12-10 Thread Sean Quah (Jira)
Sean Quah created KAFKA-18199: - Summary: Incorrect size calculation for ConsumerGroupMemberMetadataValue.classicMemberMetadata Key: KAFKA-18199 URL: https://issues.apache.org/jira/browse/KAFKA-18199 Proje

[jira] [Created] (KAFKA-17965) New group coordinator request local time excludes coordinator processing

2024-11-08 Thread Sean Quah (Jira)
Sean Quah created KAFKA-17965: - Summary: New group coordinator request local time excludes coordinator processing Key: KAFKA-17965 URL: https://issues.apache.org/jira/browse/KAFKA-17965 Project: Kafka

[jira] [Created] (KAFKA-17710) Rework UniformHeterogeneousAssignor to improve performance

2024-10-06 Thread Sean Quah (Jira)
Sean Quah created KAFKA-17710: - Summary: Rework UniformHeterogeneousAssignor to improve performance Key: KAFKA-17710 URL: https://issues.apache.org/jira/browse/KAFKA-17710 Project: Kafka Issue Ty

[jira] [Updated] (KAFKA-17495) Factor out common setup from server-side assignor benchmarks

2024-09-08 Thread Sean Quah (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sean Quah updated KAFKA-17495: -- Description: ServerSideAssignorBenchmark and TargetAssignmentBuilderBenchmark both have the same topi

[jira] [Created] (KAFKA-17496) Add heterogeneous configuration to TargetAssignmentBuilderBenchmark

2024-09-08 Thread Sean Quah (Jira)
Sean Quah created KAFKA-17496: - Summary: Add heterogeneous configuration to TargetAssignmentBuilderBenchmark Key: KAFKA-17496 URL: https://issues.apache.org/jira/browse/KAFKA-17496 Project: Kafka

[jira] [Created] (KAFKA-17495) Factor out common setup from server-side assignor benchmarks

2024-09-08 Thread Sean Quah (Jira)
Sean Quah created KAFKA-17495: - Summary: Factor out common setup from server-side assignor benchmarks Key: KAFKA-17495 URL: https://issues.apache.org/jira/browse/KAFKA-17495 Project: Kafka Issue

[jira] [Assigned] (KAFKA-17279) Handle retriable errors from offset fetches in ConsumerCoordinator

2024-08-12 Thread Sean Quah (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sean Quah reassigned KAFKA-17279: - Assignee: Sean Quah > Handle retriable errors from offset fetches in ConsumerCoordinator >

[jira] [Commented] (KAFKA-17279) Handle retriable errors from offset fetches in ConsumerCoordinator

2024-08-07 Thread Sean Quah (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871639#comment-17871639 ] Sean Quah commented on KAFKA-17279: --- Hi [~linsiyuan], thanks for volunteering. However

[jira] [Commented] (KAFKA-17267) New group coordinator can return REQUEST_TIMED_OUT for OFFSET_FETCHes

2024-08-07 Thread Sean Quah (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871640#comment-17871640 ] Sean Quah commented on KAFKA-17267: --- Hi [~frankvicky], thanks for volunteering. Howeve

[jira] [Created] (KAFKA-17279) Handle retriable errors from offset fetches in ConsumerCoordinator

2024-08-06 Thread Sean Quah (Jira)
Sean Quah created KAFKA-17279: - Summary: Handle retriable errors from offset fetches in ConsumerCoordinator Key: KAFKA-17279 URL: https://issues.apache.org/jira/browse/KAFKA-17279 Project: Kafka

[jira] [Updated] (KAFKA-17267) New group coordinator can return REQUEST_TIMED_OUT for OFFSET_FETCHes

2024-08-05 Thread Sean Quah (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sean Quah updated KAFKA-17267: -- Description: Under some circumstances, the new group coordinator can return {{REQUEST_TIMED_OUT}} err

[jira] [Created] (KAFKA-17267) New group coordinator can return REQUEST_TIMED_OUT for OFFSET_FETCHes

2024-08-05 Thread Sean Quah (Jira)
Sean Quah created KAFKA-17267: - Summary: New group coordinator can return REQUEST_TIMED_OUT for OFFSET_FETCHes Key: KAFKA-17267 URL: https://issues.apache.org/jira/browse/KAFKA-17267 Project: Kafka

[jira] [Resolved] (KAFKA-16386) NETWORK_EXCEPTIONs from transaction verification are not translated

2024-03-26 Thread Sean Quah (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sean Quah resolved KAFKA-16386. --- Fix Version/s: 3.8.0 Resolution: Fixed > NETWORK_EXCEPTIONs from transaction verification are

[jira] [Updated] (KAFKA-16386) NETWORK_EXCEPTIONs from transaction verification are not translated

2024-03-19 Thread Sean Quah (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sean Quah updated KAFKA-16386: -- Description: KAFKA-14402 ([KIP-890|https://cwiki.apache.org/confluence/display/KAFKA/KIP-890%3A+Trans

[jira] [Created] (KAFKA-16386) NETWORK_EXCEPTIONs from transaction verification are not translated

2024-03-19 Thread Sean Quah (Jira)
Sean Quah created KAFKA-16386: - Summary: NETWORK_EXCEPTIONs from transaction verification are not translated Key: KAFKA-16386 URL: https://issues.apache.org/jira/browse/KAFKA-16386 Project: Kafka