added support of kafka message headers (correlationId and replyToTopic for now)
if headers were specified in EventSendCommand, they will be used in the record, which will be send
moved parsing of kafka/protobuf/header html blocks to separate entities (see HtmlBlockParser interface) which are reused in both EventSendCommand and EventCheckReplyCommand (also will be reused in key-value module in future)
correlationId
andreplyToTopic
for now)EventSendCommand
, they will be used in the record, which will be sendHtmlBlockParser
interface) which are reused in bothEventSendCommand
andEventCheckReplyCommand
(also will be reused in key-value module in future)