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