camel-kafka-connector

camel-kafka-connector copied to clipboard

Hi Team, We are using Camel Salesforce source connector, Camel kafka source connector starts from replayId config from connector config. I would like to start connector from the stored offset...

Ziauddin135

Hi All, Please help how to publish record to kafka in batches and mention buffer size in camel salesforce Kafka source connector. Thanks!

Ziauddin135

Camel Kafka Salesforce Source connector keeps disconnecting/resubscribing and eventually fails

7

Hi all, I have been trying to troubleshoot some issues I have been seeing with the Camel Kafka Salesforce Source connector to no avail. I have two different kafka topics...

hakidehari

Hi Everyone, Please help. I am using Camel Salesforce to kafka soruce connector I am facing issue while consuming data from Push topic and publishing it to Kafka in AVRO...

Ziauddin135

The pre-release salesforce source connector, the received messages are in the format that different from Salesforce document.

1

Hi team, When I use the salesforce source connector, the received messages are in the format below ```json { "schema":{ "type":"bytes", "optional":false }, "payload":"eyJMYXN0TW9kaWZpZWREYXRlIjoiMjAyMS0xMS0xNlQwNzozMjoxMC4wMDBaIiwiV2luX1Byb2JhYmlsaXR5X19jIjozMC4wfQ==" } ``` The base64 decoded payload...

milkchocolate

KC with Event Hubs Sink 1.0.0

12

Hi. I want to use Camel Sink KafkaConnector (1.0.0) with Azure Event Hubs forwarding event to Azure, but it doesn't look like to forward headers. There is possibility to remove...

egonbaren

Consistency of Property Naming

1

Can there be more consistency of prefixes for property names in connectors? An example is the difference between the http-sink and https-sink where the http-sink connector name is camel.kamelet.http-sink.url, but...

michaelhoffmantech

I Implemented the SSH Sink Kamelet. https://github.com/apache/camel-kafka-connector/blob/main/tests/itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/sink/CamelSinkSshITCase.java#L39

oscerd

UseDefaultCredentials Provider doesn't recognize web identity token file

26

I have a AWS s3 source connector with the following configurations : ``` apiVersion: kafka.strimzi.io/v1beta2 kind: KafkaConnector metadata: name: source-connector namespace : my-namespace labels: strimzi.io/cluster: my-connect-cluster spec: class: org.apache.camel.kafkaconnector.aws2s3.CamelAws2s3SourceConnector serviceAccountName:...

arjun180

I have a AWS s3 source connector with the following configurations : ``` apiVersion: kafka.strimzi.io/v1beta2 kind: KafkaConnector metadata: name: cloudtrail-s3-source-connector namespace : my-kafka labels: strimzi.io/cluster: my-kafka-connect-cluster spec: class: org.apache.camel.kafkaconnector.aws2s3.CamelAws2s3SourceConnector tasksMax:...

arjun180