class CompositeRestoreListener implements RecordBatchingStateRestoreCallback, StateRestoreListener {

    @Override
    public void restoreBatch(final Collection<ConsumerRecord<byte[], byte[]>> records) {
        internalBatchingRestoreCallback.restoreBatch(records);
    }

      CompositeRestoreListener(final StateRestoreCallback stateRestoreCallback);

}