camel-kafka-connector

camel-kafka-connector copied to clipboard

azure datalake gen2

2

Does camel-azure-storage-datalake-kafka-connector exists on 1.0.x or 3.18.x?

bsvicente

camel-rabbitmq-source-kafka-connector: Unable to specify vhost

4

In version 3.18 of the `rabbitmq-source` Kafka connector, there is no option to specify the vhost to be used for RabbitMQ. This leads to errors like this: ``` Caused by:...

steve-criticalmention

Azure authentication erros on 3.18.x

3

Hi After upgrade from 1.0.x to 3.18.x, AzureBlobStorageSink started having erros in authentication. `2022-09-28 12:51:34,273 INFO [azure-test-sink|task-0] Package versions: jackson-annotations=2.13.3, jackson-core=2.13.3, jackson-databind=2.13.3, jackson-dataformat-xml=2.13.3, jackson-datatype-jsr310=2.13.2, azure-core=1.28.0, Troubleshooting version conflicts: https://aka.ms/azsdk/java/dependency/troubleshoot (com.azure.core.implementation.jackson.JacksonVersion)...

bsvicente

CamelSalesforcesourceSourceConnector: Failed to resolve endpoint error

8

Given the following configuration options: ``` "name":"contacts-from-salesforce", "connector.class":"org.apache.camel.kafkaconnector.salesforcesource.CamelSalesforcesourceSourceConnector", "tasks.max":1, "key.converter":"org.apache.kafka.connect.storage.StringConverter", "value.converter":"org.apache.kafka.connect.storage.StringConverter", "camel.kamelet.salesforce-source.query":"SELECT Id, Name, Email, Phone FROM Contact", "camel.kamelet.salesforce-source.topicName":"salesforce-contacts", "camel.kamelet.salesforce-source.loginUrl":"https://my--sandbox.my.salesforce.com", "camel.kamelet.salesforce-source.notifyForFields":"ALL", "camel.kamelet.salesforce-source.clientId":"CLIENT_ID", "camel.kamelet.salesforce-source.clientSecret":"CLIENT_SECRET", "camel.kamelet.salesforce-source.userName":"USER_NAME", "camel.kamelet.salesforce-source.password":"PASSWORD", ``` the connector is getting...

mdimas

Hello, I want to build the mqtt source connector in a kafka cluster deployed using STRIMZI but, no matter what I try, I keep getting this error: ``` state: FAILED...

GrSof

Directory name for Azure Datalake Kafka sink Connector

3

Hi @oscerd , Sorry to pour questions to you , This is the last one I am asking you , Right now fileName is working fine if we pass from...

AishD3

File name format and File Format in Azure Data Lake Sink Connector

27

In Azure Datalake Sink connector , when we move events from Kafka to Gen 2 data lake, Is it possible to configure file name format and file type format like...

AishD3

Kafka Events batching

4

Hi @oscerd , we would like batch some amount of kafka records while a file is created in data lake . We are using below configs in Kafka Connect for...

AishD3

CamelSalesforcesourceSourceConnector: Does not return Id/sObjectId from Salesforce

7

**Connector:** v3.18.2 #### Issue: The salesforce source kafka connector does not contain the salesforce recordId/sObjectId on any event - Create, Update etc. Its not in the message value nor in...

apoorvmintri

Bumps [org.postgresql:postgresql](https://github.com/pgjdbc/pgjdbc) from 42.7.1 to 42.7.2. Changelog Sourced from org.postgresql:postgresql's changelog. Changelog Notable changes since version 42.0.0, read the complete History of Changes. The format is based on Keep a...

dependabot[bot]