You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@kafka.apache.org by "Jason Gustafson (Jira)" <ji...@apache.org> on 2020/12/07 17:41:00 UTC

[jira] [Created] (KAFKA-10817) Add clusterId validation to Fetch handling

Jason Gustafson created KAFKA-10817:
---------------------------------------

             Summary: Add clusterId validation to Fetch handling
                 Key: KAFKA-10817
                 URL: https://issues.apache.org/jira/browse/KAFKA-10817
             Project: Kafka
          Issue Type: Sub-task
            Reporter: Jason Gustafson
            Assignee: David Jacot


Initially we were unsure how the clusterId would be generated by the cluster after Zookeeper removal, so we did not implement it. It is looking now like we will probably require users to generate it manually prior to starting the cluster. See here for details: https://cwiki.apache.org/confluence/display/KAFKA/KIP-631%3A+The+Quorum-based+Kafka+Controller#KIP631:TheQuorumbasedKafkaController-Fencing. In this case, we can assume that the clusterId will be provided when instantiating the raft client, so we can add the logic to the request handler to validate it in inbound Fetch requests.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)