You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2023/02/09 21:48:00 UTC
[jira] [Created] (KAFKA-14703) Don't resign when failing to replay uncommitted records
José Armando García Sancio created KAFKA-14703:
--------------------------------------------------
Summary: Don't resign when failing to replay uncommitted records
Key: KAFKA-14703
URL: https://issues.apache.org/jira/browse/KAFKA-14703
Project: Kafka
Issue Type: Improvement
Components: controller
Reporter: José Armando García Sancio
h1. Problem
The KRaft controller is replays both committed and uncommitted records. Committed records are replayed by the inactive controller. Uncommitted records are replayed by the active controller.
When handling an RPC the active controller generates a response and a list of uncommitted records. The active controller replays the uncommitted records before sending them to the KRaft layer for durability and replication. If the active controller encounters an error when replaying the uncommitted records, it calls the process exit fault handler.
Indirectly, the process exit fault handler resigns its KRaft leadership and closes all of the client connections.
Most clients to retry the RPC when they disconnect from the remote endpoint. If the RPC's replay error is deterministic then it is possible for the failure to propagate to all of the controllers as they become leaders. This handling may cause the controllers to become unavailable.
h1. Solution
We can avoid this failure from propagating to all of the controllers by changing how we handle errors when replaying uncommitted records. The active controller doesn't need to fatally exit, if it failed to replay an uncommitted record. The active controller should instead failed the RPC with an UNKNOWN_ERROR and revert the in-memory state to the in-memory snapshot before the RPC was handled.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)