У меня есть производитель Kafka, отправляющий данные с помощью KafkaTemplate.send(). В ProducerRecord я добавляю заголовок с ключевой временной меткой и добавляю собственное значение временной метки. У меня есть потребительские записи, использующие объект @KafkaListener для ConsumerRecord.
Когда я пытаюсь получить доступ к заголовку timestamp из этой потребительской записи, я получить значение, которое я отправляю от производителя.
Теперь у меня есть еще один потребитель, написанный с использованием Consumer в качестве bean-компонента. Здесь конфигурации Kafka выполняются с использованием привязки Kafka (spring.cloud.stream.kafka). Когда я извлекаю заголовок timestamp из полученного объекта Message, значение отличается от того, которое я отправляю от производителя.
Как это исправить? Есть ли способ повторно использовать исходный ключ временной метки и сохранить собственное значение временной метки?
Подробнее здесь: https://stackoverflow.com/questions/790 ... t-consumer
