camel-kafka-connector
camel-kafka-connector copied to clipboard
apache
Camel Kafka Connector allows you to use all Camel components as Kafka Connect connectors
Periodic Sync of Camel Kafka connector main Branch with main Camel Main. see https://github.com/apache/camel-kafka-connector/blob/main/.github/workflows/automatic-sync-camel-main.yml
![github-actions[bot] avatar](https://avatars.githubusercontent.com/in/15368?v=4 "github-actions[bot] avatar"){kind=avatar}
Hi there I'm currently using version 1.0.0 to read from an FTP into Kafka. So far this works like a charm. However, there is a new requirement that I need...
I am using the 0.11.x CamelRabbitmqSourceConnector connector with docker-compose and connect-standalone. I have things working in TCP but I would like to get it working in SSL. The docs mentions...
Bumps [postgresql](https://github.com/pgjdbc/pgjdbc) from 42.3.3 to 42.4.1. Release notes Sourced from postgresql's releases. 42.4.0 What's Changed Enhancement: Made TimestampUtils.utcTz static and renamed to UTC_TIMEZONE by @svendiedrichsen in pgjdbc/pgjdbc#2519 fix: return correct...
![dependabot[bot] avatar](https://avatars.githubusercontent.com/in/29110?v=4 "dependabot[bot] avatar"){kind=avatar}
Bumps [postgresql](https://github.com/pgjdbc/pgjdbc) from 42.3.3 to 42.4.1. Release notes Sourced from postgresql's releases. 42.4.0 What's Changed Enhancement: Made TimestampUtils.utcTz static and renamed to UTC_TIMEZONE by @svendiedrichsen in pgjdbc/pgjdbc#2519 fix: return correct...
Bumps [postgresql](https://github.com/pgjdbc/pgjdbc) from 42.3.3 to 42.4.1. Release notes Sourced from postgresql's releases. 42.4.0 What's Changed Enhancement: Made TimestampUtils.utcTz static and renamed to UTC_TIMEZONE by @svendiedrichsen in pgjdbc/pgjdbc#2519 fix: return correct...
Hi, I have a requirement to push the events from Kafka topic to AWS event bridge. Couldn't find any other connectors apart from camel-aws2-eventbridge-kafka-connector. So i wanted to give a...
I have the following .json for creating the hdfs-kafka connector `{ "name":"CamelHdfsSinkConnector", "config":{ "connector.class":"org.apache.camel.kafkaconnector.hdfs.CamelHdfsSinkConnector", "task.max":2, "key.converter":"org.apache.kafka.connect.storage.StringConverter", "value.converter":"org.apache.kafka.connect.storage.StringConverter", "transforms": "CamelTypeConverterTransform", "transforms.CamelTypeConverterTransform.type": "org.apache.camel.kafkaconnector.transforms.CamelTypeConverterTransform$Value", "transforms.CamelTypeConverterTransform.target.type":"java.lang.String", "topics":"xxxx", "camel.sink.path.hostName": "xxxx", "camel.sink.endpoint.namedNodes": "namenode-1:8020,namenode-2:8020", "camel.sink.endpoint.splitStrategy": "IDLE:100000,BYTES:132120576", "camel.sink.endpoint.compressionCodec":...
Greetings, I'm facing some issues understanding how to correctly define the jira connector auth system using accessToken, consumerKey, privateKey and verification code as stated in the documentation of the component...
