public boolean equals()

in flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriterState.java [76:89]

• 14 lines of code
• 8 McCabe index (conditional complexity)

    public boolean equals(Object object) {
        if (this == object) {
            return true;
        }
        if (object == null || getClass() != object.getClass()) {
            return false;
        }
        KafkaWriterState that = (KafkaWriterState) object;
        return ownedSubtaskId == that.ownedSubtaskId
                && totalNumberOfOwnedSubtasks == that.totalNumberOfOwnedSubtasks
                && Objects.equals(transactionalIdPrefix, that.transactionalIdPrefix)
                && transactionOwnership == that.transactionOwnership
                && Objects.equals(precommittedTransactionalIds, that.precommittedTransactionalIds);
    }