public String leader() {
            return leader;
        }
Return the ID of the leader Connect worker in this assignment.

@return the ID of the leader
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/ConnectProtocol.java