Closed
Description
Hi everybody,
This Issue was originally posted by me in Zulip
I am currently trying to accept text or json messages via the CamelNettyhttpSourceConnector component.
I use the following configuration:
{
"connector.class": "org.apache.camel.kafkaconnector.nettyhttp.CamelNettyhttpSourceConnector",
"camel.source.endpoint.receiveBufferSize": "10",
"camel.source.path.host": "0.0.0.0",
"camel.source.path.protocol": "http",
"tasks.max": "1",
"topics": "test",
"camel.source.path.port": "8081",
"name": "http",
"value.converter": "org.apache.kafka.connect.storage.StringConverter",
"key.converter": "org.apache.kafka.connect.storage.StringConverter"
}
I send messages to the connector with:
curl -H "Content-Type: text/plain" -X POST -d '{"username":"xyz","password":"xyz"}' http://localhost:8081
or
curl -H "Content-Type: application/json" -X POST -d '{"username":"xyz","password":"xyz"}' http://localhost:8081
The messages end up in my topic "test" but there is just a bunch of org.apache.camel.component.netty.http.NettyChannelBufferStreamCache Objects or sometimes even empty objects.
The error occurs with version 0.7.0 and 0.7.1. I just downloaded the tar archives from the components page in the respective versions and extracted them into my kafka connect connector folder (Cloudera CDP 7.1)
Thank you very much.