@Override
    public boolean equals(Object o) {
        if (this == o) return true;
        if (o == null || getClass() != o.getClass()) return false;
        ClusterConfigState that = (ClusterConfigState) o;
        return offset == that.offset &&
                Objects.equals(sessionKey, that.sessionKey) &&
                Objects.equals(connectorTaskCounts, that.connectorTaskCounts) &&
                Objects.equals(connectorConfigs, that.connectorConfigs) &&
                Objects.equals(connectorTargetStates, that.connectorTargetStates) &&
                Objects.equals(taskConfigs, that.taskConfigs) &&
                Objects.equals(inconsistentConnectors, that.inconsistentConnectors) &&
                Objects.equals(configTransformer, that.configTransformer);
    }
Get the set of connectors which have inconsistent data in this snapshot. These inconsistencies can occur due to
partially completed writes combined with log compaction.
<p>
Connectors in this set will appear in the output of {@link #connectors()} since their connector configuration is
available, but not in the output of {@link #tasks(String)} since the task configs are incomplete.
<p>
When a worker detects a connector in this state, it should request that the connector regenerate its task
configurations.

@return the set of inconsistent connectors
connect/runtime/src/main/java/org/apache/kafka/connect/storage/ClusterConfigState.java