En Kafka, cómo obtener el desplazamiento exacto según el tiempo de producción

Necesito recibir el mensaje producido en Kafka hora por hora en un día. Cada hora iniciaré un trabajo para consumir el mensaje producido hace 1 hora. por ejemplo, si la hora actual es 20:12, consumiré el mensaje entre las 19:00:00 y las 19:59:59. Eso significa que necesito comenzar el desplazamiento por hora 19:00:00 y finalizar el desplazamiento por hora 19:59:59. Usé SimpleConsumer.getOffsetsBefore como se muestra en 「0.8.0 Ejemplo de consumidor simple」. El problema es que el desplazamiento de retorno no coincide con la marca de tiempo dada como parámetro. p.ej. Cuando hago la marca de tiempo 19:00:00, recibo el mensaje producido a la hora 16:38:00.

Respuestas a la pregunta(5)

Su respuesta a la pregunta