public boolean equals()

in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartitionLeader.java [68:84]

• 15 lines of code
• 6 McCabe index (conditional complexity)

    public boolean equals(Object o) {
        if (this == o) {
            return true;
        }
        if (!(o instanceof KafkaTopicPartitionLeader)) {
            return false;
        }

        KafkaTopicPartitionLeader that = (KafkaTopicPartitionLeader) o;

        if (!topicPartition.equals(that.topicPartition)) {
            return false;
        }
        return leaderId == that.leaderId
                && leaderPort == that.leaderPort
                && leaderHost.equals(that.leaderHost);
    }