Lightning.KafkaTriggers.DuplicateTrackingCleanupWorker (Lightning v2.13.5)
View SourceResponsible for cleaning up stale TriggerKafkaMessageRecords entries. TriggerKafkaMessageRecords are used to deduplicate incoming messages from a Kafka cluster.
Responsible for cleaning up stale TriggerKafkaMessageRecords entries. TriggerKafkaMessageRecords are used to deduplicate incoming messages from a Kafka cluster.