org.apache.kafka.streams.processor

Interface CommitCallback

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@InterfaceStability.Evolving
 @FunctionalInterface
public interface CommitCallback

Stores can register this callback to be notified upon successful commit.

Method Summary

Modifier and Type	Method and Description
void	onCommit()

Method Detail

onCommit

void onCommit()
       throws IOException

Throws:

IOException