in src/main/java/org/apache/doris/kafka/connector/writer/commit/DorisCommittable.java [80:91]
public boolean equals(Object o) {
if (this == o) {
return true;
}
if (o == null || getClass() != o.getClass()) {
return false;
}
DorisCommittable that = (DorisCommittable) o;
return txnID == that.txnID
&& Objects.equals(hostPort, that.hostPort)
&& Objects.equals(db, that.db);
}