[
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
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
[
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
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
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
[
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
[
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}
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
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
[
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.
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
[
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
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
[
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
[
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
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
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
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
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
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
[
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
> -
>
>
[
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
[
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
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
[
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
[
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
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
[
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
> -
[
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
> -
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
[
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
> ---
[
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
[
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
[
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
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
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
[
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)
[
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)
[
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)
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
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
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
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
[
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
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
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
[
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
>
[
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
[
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
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
[
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
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
[
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
[
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
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
55 matches
Mail list logo