Interface RecordBatchingStateRestoreCallback

    • Method Detail

      • restoreBatch

        void restoreBatch​(java.util.Collection<org.apache.kafka.clients.consumer.ConsumerRecord<byte[],​byte[]>> records)