feature: add kafka headers support to kafka executor consumer implementation

[gena01]

I was trying to write tests against message(s) posted to kafka and to write asserts against kafka headers posted from kafka. Looks like the headers are not available/exposed to the test suite for the kafka consumer (even after messing with kafka_version)