valdar commented on issue #1324:
URL:
https://github.com/apache/camel-kafka-connector/issues/1324#issuecomment-1028191387
> Here is an example of a message + headers, formatted with kcat:
>
> ```
> Key (-1 bytes):
> Value (141 bytes):
{"CorrelationId":"a529A3D7-e15f-3d21e-315t6r5-e54csda23dbadQwfh3a1","Message":"Example","Timestamp":"2022-01-22T17:19:43.459939+00:00"}
> Headers:
> Digest=U0hBLTUxMi8yNTY9dTkAocasnkjzvASOfuqnfsoiuds87101jsmNiTGQ2YUdFWT0=,
>
Signature-Input=bW9uZXNNcaiuhasfhASIUWqosidfachsuczkjxvnduaW5nLWtleS0xIg==,
>
Signature=bW9uZAkjanscavbchjzxbchbauysfwqoaicocxjaoDRvRFFyeXhURDJJklghyu6==
> ```
@Doug-North @johnnyreilly so if the above is an example of message sent to
the sink connector those headers should be called: `CamelHeader.Digest`,
`CamelHeader.Signature-Input` and `CamelHeader.Signature`.
Would be nice if you could try with those names and see what happens.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
