Slackbot
09/14/2022, 6:08 AMKaran Kumar
09/14/2022, 6:14 AMnaresh nallappa
09/14/2022, 6:30 AMnaresh nallappa
09/14/2022, 6:54 AMHemanth Patil
09/14/2022, 7:09 AMdruid.coordinator.kill.durationToRetain is set to 60min. We can increase it so that the Kill tasks when started does not have the lock revoked because of late data arriving in your Kafka stream.
Another option is to set lateMessageRejectionPeriod in your Kafka stream which might drop the late data arriving. But this is not recommended as it will drop the events completely.Karan Kumar
09/14/2022, 7:18 AM