카프카 (Kafka) : 처음 발행 된 시간에 24 시간 동안 메시지를 다시 게시하십시오.

카프카 (자정부터 자정까지)에 24 시간 동안 메시지를 게시했습니다. 약 120 만 개의 메시지가 있습니다.카프카 (Kafka) : 처음 발행 된 시간에 24 시간 동안 메시지를 다시 게시하십시오.

테스트 목적으로이 로그를 사용하여 자정에 시작하여 로그를 읽고 처음에 보낸 각 메시지를 다시 게시하기 위해이 로그를 사용하고 싶습니다.

이 작업을 수행하는 도구 또는 라이브러리 (이상적으로는 Java 또는 스칼라)가 있습니까?

2017-10-23 david

당신은 지정된 오프셋 (offset)에 되감기하고 다음 자정까지 기록을 생산 & 소비, 카프카 0.10 이후 사용할 수있는 offsetsForTimes를 사용하여 같은 것을 쓸 수

2017-10-23 20:27:02

답변