Прослушивателей может быть несколько, но есть два типа: один получает заголовки:
Код: Выделить всё
@KafkaListener(...)
public void processMessage(String message,
ConsumerRecordMetadata metadata,
@Header(name = ID, required = false) String id,
@Header(name = TIME, required = false) String time) {
var headers = Map.of(ID, id, TIME, time);
...
}
Код: Выделить всё
@KafkaListener(...)
public void processMessage(String message,
ConsumerRecordMetadata metadata) {
var headers = Map.of();
...
}
И да, такое происходит :|
Подробнее здесь: https://stackoverflow.com/questions/784 ... empty-maps