git.net

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

KafkaHeaderFilterStrategy bug?


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



( ! ) Warning: include(msgfooter.php): failed to open stream: No such file or directory in /var/www/git/apache-camel-users/msg03518.html on line 86
Call Stack
#TimeMemoryFunctionLocation
10.0011362520{main}( ).../msg03518.html:0

( ! ) Warning: include(): Failed opening 'msgfooter.php' for inclusion (include_path='.:/var/www/git') in /var/www/git/apache-camel-users/msg03518.html on line 86
Call Stack
#TimeMemoryFunctionLocation
10.0011362520{main}( ).../msg03518.html:0