Hi,
maybe you can use AbstractStreamOperatorTestHarness to test your source,
including the snapshotting. You can take a look at the tests of some other
source, e.g. StatefulSequenceSourceTest#testCheckpointRestore.
Best,
Stefan
> Am 20.09.2018 um 15:29 schrieb Darshan Singh :
>
> Hi,
>
> I a
Hi,
I am writing a stateful source very similar to KafkaBaseConsumer but not as
generic. I was looking on how we can use unit test cases and integration
tests on this. I looked at the kafka-connector-based unit test cases. It
seems that there is too much external things at play here like lots of
