Thanks for the reply.
It seems the following class in newer release can do what the test needs:
class OffsetCheckpointFile(val file: File, logDirFailureChannel:
LogDirFailureChannel = null) {
Cheers
On Thu, May 31, 2018 at 9:27 AM, Ismael Juma wrote:
> Hi Ted,
>
> There are two such classes.
Hi Ted,
There are two such classes. The example you have is for the broker class,
not the Streams one.
Ismael
On Thu, 31 May 2018, 09:03 Ted Yu, wrote:
> Hi,
> OffsetCheckpoint has been relocated
> to org.apache.kafka.streams.state.internals package.
>
> Does this mean that downstream project
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 offset
