Hi All,

Is there any way I can inspect/query the checkpointed data. Scenario is
like this -

We have a high volume of data coming in the data stream pipeline for which
kafka is source, in case if fails bcoz of bad data I want to analyse the
data which caused the issue. It could be that some data source starts
sending bad data so I want to go in kafka to that particular offset and do
some analysis before I start the job with checkpointed data.

Can anyone suggest how this can be achieved.

Thanks,
Hemant

Reply via email to