Использовать сообщение START из темы Kafka, искать сообщение END с тем же UID; ошибка журнала, если сообщение END не прочитано в течение 24 часов

Question

Необходимо написать приложение Kafka на Java, которое читает сообщение JSON, например:

{"UID": "1234-5678", "type": "START"}

после прочтения этого сообщения существует SLA на 24 часа для сообщения END, предназначенного для использования из той же темы

{"UID": "1234-5678", "type": "END"}

если этот тип: сообщение END не найдено, должно появиться сообщение об ошибке на консоли.