KafkaHeaderFilterStrategy bug?

Previous Topic Next Topic
 
classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

KafkaHeaderFilterStrategy bug?

daknin
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
Reply | Threaded
Open this post in threaded view
|

R: KafkaHeaderFilterStrategy bug?

Andrea Cosentino-2
What is the camel versione you're talking about?

Inviato da Yahoo Mail su Android
 
  Il sab, 21 lug, 2018 alle 21:34, Darrell King<[hidden email]> ha scritto:   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