in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java [1846:1860]
public boolean equals(Object o) {
if (this == o) {
return true;
}
if (o == null || getClass() != o.getClass()) {
return false;
}
NextTransactionalIdHint that = (NextTransactionalIdHint) o;
if (lastParallelism != that.lastParallelism) {
return false;
}
return nextFreeTransactionalId == that.nextFreeTransactionalId;
}