Получить метку времени, когда полезная нагрузка опубликована в теме - PullRequest
Новая
       9

Получить метку времени, когда полезная нагрузка опубликована в теме

0 голосов
/ 29 апреля 2019

У меня есть приложение kafka-streams, в котором полезная нагрузка проходит через несколько тем, скажем, оно начинается с темы A-> B-> c-> .. -> L и заканчивается на L. У меня есть требование выяснить, скольковремя, которое потребовалось для получения данных в теме L.

из пользовательского API, которое я использовал 

while (iterator.hasNext()){
    ConsumerRecord<String,String> consumerRecord =iterator.next();
    map.put(consumerRecord.key(),consumerRecord.timestamp()); 
}

, отметка времени дает мне, когда сообщение публикуется в теме A, но я хотел знать, когдасообщение было опубликовано в теме L.

Может ли кто-нибудь помочь мне, как получить это значение ..?

...