Hi, I think there might be a small bug when invoking KafkaHeaderFilterStrategy.
KafkaProducer.java calls: headerFilterStrategy.applyFilterToExternalHeaders(entry.getKey(), entry.getValue(), exchange) KafkaConsumer.java calls: headerFilterStrategy.applyFilterToCamelHeaders(header.key(), header.value(), exchange) I think KafkaProducer should be calling applyFilterToCamelHeaders and KafkaConsumer should be calling applyFilterToExternalHeaders. regards Darrell
