kora
kora copied to clipboard
@KafkaListener headers support
Features will allow to receive Kafka Headers for custom methods in @KafkaListener
public class KafkaListenerClass {
@KafkaListener("test.config.path")
public void process(String key, String value, Headers headers) {
}
}