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
