[jira] [Updated] (KAFKA-15455) Add support for OffsetCommit version 9 in consumer

[ https://issues.apache.org/jira/browse/KAFKA-15455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Ding updated KAFKA-15455: Labels: kip-848 kip-848-client-support kip-848-e2e kip-848-preview (was: kip-848 kip-848-client-support k

[jira] [Updated] (KAFKA-15321) Document consumer group member state machine

[ https://issues.apache.org/jira/browse/KAFKA-15321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Ding updated KAFKA-15321: Labels: kip-848 kip-848-client-support (was: kip-848 kip-848-client-support kip-848-preview) > Document

[jira] [Updated] (KAFKA-15534) Propagate client response time when timeout to the request handler

[ https://issues.apache.org/jira/browse/KAFKA-15534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Ding updated KAFKA-15534: Labels: consumer-threading-refactor kip-848 kip-848-client-support kip-848-e2e kip-848-preview (was: cons

[jira] [Updated] (KAFKA-15548) Handling close() properly

[ https://issues.apache.org/jira/browse/KAFKA-15548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Ding updated KAFKA-15548: Labels: consumer-threading-refactor kip-848 kip-848-client-support kip-848-preview (was: consumer-threadi

[jira] [Updated] (KAFKA-15548) Handling close() properly

[ https://issues.apache.org/jira/browse/KAFKA-15548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Ding updated KAFKA-15548: Labels: consumer-threading-refactor kip- (was: consumer-threading-refactor) > Handling close() properly >

[jira] [Updated] (KAFKA-15276) Implement partition assignment reconciliation

[ https://issues.apache.org/jira/browse/KAFKA-15276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Ding updated KAFKA-15276: Labels: kip-848 kip-848-client-support kip-848-e2e kip-848-preview (was: kip-848 kip-848-client-support k

[jira] [Updated] (KAFKA-15278) Implement client support for KIP-848 ConsumerGroupHeartbeat protocol RPC

[ https://issues.apache.org/jira/browse/KAFKA-15278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Ding updated KAFKA-15278: Labels: consumer-threading-refactor kip-848 kip-848-client-support kip-848-e2e kip-848-preview (was: cons

[jira] [Updated] (KAFKA-15280) Implement client support for KIP-848 server-side assignors

[ https://issues.apache.org/jira/browse/KAFKA-15280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Ding updated KAFKA-15280: Labels: consumer-threading-refactor kip-848 kip-848-client-support kip-848-e2e kip-848-preview (was: cons

[jira] [Updated] (KAFKA-15531) Ensure coordinator node is removed upon disconnection exception

[ https://issues.apache.org/jira/browse/KAFKA-15531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Ding updated KAFKA-15531: Labels: kip-848 kip-848-client-support kip-848-e2e kip-848-preview (was: kip-848 kip-848-client-support k

[jira] [Updated] (KAFKA-15542) Release member assignments on errors

[ https://issues.apache.org/jira/browse/KAFKA-15542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Ding updated KAFKA-15542: Labels: kip-848 kip-848-client-support kip-848-e2e kip-848-preview (was: kip-848 kip-848-client-support k

[jira] [Updated] (KAFKA-15540) Handle heartbeat and revocation when consumer leaves group

[ https://issues.apache.org/jira/browse/KAFKA-15540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Ding updated KAFKA-15540: Labels: kip-848 kip-848-client-support kip-848-e2e kip-848-preview (was: kip-848 kip-848-client-support k

[jira] [Updated] (KAFKA-15533) Ensure HeartbeatRequestManager only send out some fields once

[ https://issues.apache.org/jira/browse/KAFKA-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Ding updated KAFKA-15533: Labels: kip-848-e2e kip-848-preview (was: kip-848-preview) > Ensure HeartbeatRequestManager only send out

[jira] [Updated] (KAFKA-15543) Send HB request right after reconciliation completes

[ https://issues.apache.org/jira/browse/KAFKA-15543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Ding updated KAFKA-15543: Labels: kip-848 kip-848-client-support kip-848-e2e kip-848-preview (was: kip-848 kip-848-client-support k

[jira] [Updated] (KAFKA-15554) Update client state machine to align with protocol sending one assignment at a time

[ https://issues.apache.org/jira/browse/KAFKA-15554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Ding updated KAFKA-15554: Labels: kip-848-client-support kip-848-e2e kip-848-preview (was: kip-848-client-support kip-848-preview)

[jira] [Updated] (KAFKA-15539) Client should stop fetching while partitions being revoked

[ https://issues.apache.org/jira/browse/KAFKA-15539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Ding updated KAFKA-15539: Labels: kip-848 kip-848-client-support kip-848-preview (was: kip-848 kip-848-client-support) > Client sh

[jira] [Updated] (KAFKA-15325) Integrate topicId in OffsetFetch and OffsetCommit async consumer calls

[ https://issues.apache.org/jira/browse/KAFKA-15325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Ding updated KAFKA-15325: Labels: kip-848 kip-848-client-support kip-848-preview (was: kip-848 kip-848-client-support) > Integrate

[jira] [Updated] (KAFKA-15276) Implement partition assignment reconciliation

[ https://issues.apache.org/jira/browse/KAFKA-15276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Ding updated KAFKA-15276: Labels: kip-848 kip-848-client-support kip-848-preview (was: kip-848 kip-848-client-support) > Implement

[jira] [Updated] (KAFKA-15321) Document consumer group member state machine

[ https://issues.apache.org/jira/browse/KAFKA-15321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Ding updated KAFKA-15321: Labels: kip-848 kip-848-client-support kip-848-preview (was: kip-848 kip-848-client-support) > Document

[jira] [Updated] (KAFKA-15280) Implement client support for KIP-848 server-side assignors

[ https://issues.apache.org/jira/browse/KAFKA-15280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Ding updated KAFKA-15280: Labels: consumer-threading-refactor kip-848 kip-848-client-support kip-848-preview (was: consumer-threadi

[jira] [Updated] (KAFKA-15278) Implement client support for KIP-848 ConsumerGroupHeartbeat protocol RPC

[ https://issues.apache.org/jira/browse/KAFKA-15278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Ding updated KAFKA-15278: Labels: consumer-threading-refactor kip-848 kip-848-client-support kip-848-preview (was: consumer-threadi

[jira] [Updated] (KAFKA-15544) Enable existing client integration tests for new protocol

[ https://issues.apache.org/jira/browse/KAFKA-15544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Ding updated KAFKA-15544: Labels: kip-848 kip-848-client-support kip-848-preview (was: kip-848 kip-848-client-support) > Enable ex

[jira] [Reopened] (KAFKA-14255) Fetching from follower should be disallowed if fetch from follower is disabled

[ https://issues.apache.org/jira/browse/KAFKA-14255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Ding reopened KAFKA-14255: - > Fetching from follower should be disallowed if fetch from follower is disabled > -

[jira] [Resolved] (KAFKA-14255) Fetching from follower should be disallowed if fetch from follower is disabled

[ https://issues.apache.org/jira/browse/KAFKA-14255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Ding resolved KAFKA-14255. - Resolution: Won't Fix > Fetching from follower should be disallowed if fetch from follower is disabled >

[jira] [Commented] (KAFKA-7635) FetcherThread stops processing after "Error processing data for partition"

[ https://issues.apache.org/jira/browse/KAFKA-7635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17337705#comment-17337705 ] Yi Ding commented on KAFKA-7635: This bug has been fixed by KIP-461: [https://cwiki.apac

[jira] [Commented] (KAFKA-12207) Do not maintain list of latest producer append information

[ https://issues.apache.org/jira/browse/KAFKA-12207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17325405#comment-17325405 ] Yi Ding commented on KAFKA-12207: - We can remove the restriction on `max.in.flight.reque