shared-infrastructure/com.vertyll.veds.sharedinfrastructure.kafka/ProcessedEventGuard/claim

claim

fun claim(eventId: String, consumerGroup: String): Boolean(source)

Atomically claims eventId for consumerGroup.

Return

true if the event was claimed for the first time and the caller should proceed with processing; false if it was already processed (duplicate) and the caller should skip.