druid-io/tranquility

How to collect records which were dropped by Tranquility Kafka?

fanwu72 opened this issue · 0 comments

Hi there,

I would like to collect the dropped records(outside window period) and issue a delta batch ingestion based on these records. Is there any way to dump them to files or even logs?
Any inputs would be helpful. Thank you.

Best regards,
Ryan