referencing OffsetCheckpoint in downstream project

[Ted Yu]

Hi,
OffsetCheckpoint has been relocated
to org.apache.kafka.streams.state.internals package.

Does this mean that downstream project should no longer reference this
class ?

This is how the class is used (against Kafka 0.10.0.1 release) :

    // ensure that topic is removed from all cleaner offsets
    assert(servers.forall(server => topicAndPartitions.forall { tp =>
      val checkpoints = server.getLogManager().logDirs.map { logDir =>
        new OffsetCheckpoint(new File(logDir,
"cleaner-offset-checkpoint")).read()
      }
      checkpoints.forall(checkpointsPerLogDir =>
!checkpointsPerLogDir.contains(tp))
    }), s"checkpoint for topic $topic still exists")

Cheers