-
Notifications
You must be signed in to change notification settings - Fork 43
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Add HTTP Connector Example #323
Comments
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. |
Ok, so I am using the unofficial strimzi-cli here for local testing and Strimzi is running in kubernetes. I made a file called 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:
I see my consumers do get the message including the connector. 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:
|
I would use Kafkacat and add a -H CamelHeader.Authorization="Bearer 123token456" |
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. |
I'm having a lot of trouble trying to figure out how to use the HTTP connector with an endpoint which needs a bearer token in the Authorization header. Please add some http examples using auth tokens
The text was updated successfully, but these errors were encountered: