camel-kafka-connector-examples
camel-kafka-connector-examples copied to clipboard
apache
Apache Camel Kafka Connector Examples
Hello I am getting message.max.bytes error when trying to read logs files (pain text) of 300MB. As far as I know, the connector moves the whole file in one record...
I am using the google sheet sink connector of camel-Kafka-connector version 0.11.x. I am deploying a camel-Kafka-connector in Kubernetes. I am using the following configuration in the Kubernetes kind Kafka...
For example, Camel Twitter connector examples get a lengthy tweet message format like this with the default `org.apache.kafka.connect.storage.StringConverter`. > StatusJSONImpl{createdAt=Thu Jan 21 19:40:53 UTC 2021, id=1352340411239559170, text='We released Apache Camel...
@ffang if you have time to add an example here, it would be nice. Thanks.
Sample configuration for the MongoDB sink: connector.class=org.apache.camel.kafkaconnector.mongodb.CamelMongodbSinkConnector camel.sink.endpoint.operation=insert camel.sink.endpoint.collection=testRecords tasks.max=1 topics=org.apache.camel.kafkaconnector.mongodb.sink.CamelSinkMongoDBITCase name=CamelMongoDBSinkConnector value.converter=org.apache.kafka.connect.storage.StringConverter camel.sink.path.connectionBean=mongo camel.beans.mongo=#class:com.mongodb.client.MongoClients#create('mongodb://localhost:32772') camel.sink.endpoint.database=testDB key.converter=org.apache.kafka.connect.storage.StringConverter An important bit for the mongoDB sink is to configure the camel.beans.mongo property...