Add HTTP Connector Example about camel-kafka-connector-examples HOT 4 CLOSED

You just need to send an header together with the payload to the sink connector. This header should be named "CamelHeader.Authorization" with the bearer token as value.

from camel-kafka-connector-examples.

Ok, so I am using the unofficial strimzi-cli here for local testing and Strimzi is running in kubernetes.

I made a file called producer.properties with the following on my local machine:

CamelHeader.Authorization=Bearer 123token456

Then I run this command to create a producer from the cli

kfk console-producer --topic my-topic -c my-cluster -n default --producer.config producer.properties

Then I paste the following:

{"message": "foo"}

I see my consumers do get the message including the connector.
However I am still getting 403 back from the endpoint from within the sink connector.
Did I even do what you are saying?

How to debug the actual request getting made to the endpoint? I want to see the headers, body and all.

I also get this warning when I open the producer terminal:

WARN The configuration 'CamelHeader.Authorization' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)

from camel-kafka-connector-examples.

I would use Kafkacat and add a

-H CamelHeader.Authorization="Bearer 123token456"

from camel-kafka-connector-examples.

Oh my hero! Kafkacat worked well for me. It looks like there is a bug in the Strimzi CLI. I was pulling my hair out. I'll let them know something isn't working right. Thanks.

from camel-kafka-connector-examples.