camel-kafka-connector
camel-kafka-connector copied to clipboard
apache
Camel Kafka Connector allows you to use all Camel components as Kafka Connect connectors
Azure ServiceBus connector doesn't allow me to configure if topicOrQueueName is topic or queue. Therefor if I provide topic with subscriptionName connector failes on error: `[kafka-artemis-azure-servicebus-connector|task-0] Error processing exchange. Exchange[]....
we are trying to use CAMEL-SALESFORCE-UPDATE-SINK-KAFKA-CONNECTOR for our use case but found something inflexible in the connector config properties Property **camel.kamelet.salesforce-update-sink.clientId = Required The ID of the Salesforce object. Required...
Hi, I am checking the connector and I noticed the camel-sap-netweaver module was not included, is there any reason? should I attempt on my own ? Thanks, J
Hi I have used camel kafka not secure sink connector in my kafka connect cluster, the values are being sent with no problem but the keys on the destination are...
Hi, I am struggling to use CamelDDBStreamSourceConnector for DynamoDB change capture. Could you please advice me how to get over them? 1. I have tried several common converters for Kafka...
Hello! I am trying to use the CamelKafkasslsinkSinkConnector to move a binary payload from one kafka cluster to another. Messages are being produced on the target cluster, but they payload...
Salesforce is shifting to grpc pubsub for platform events. It would be nice if this supported the grps pubsub api. The feature is being added in Camel 4.x.
I'm using camel-netty-http-kafka-connector version 3.20.3: ```xml org.apache.camel.kafkaconnector camel-netty-http-kafka-connector 3.20.3 org.slf4j slf4j-api ``` with Kafka and Kafka Connect version `2.8.2` with the following connector.properties for netty http kafka connector: ```properties name=http-source-2...
Hi, in our Kafka Connect cluster we deploy several instances of Event Hub connectors. Recently, we've noticed that connector name printed in the error logs is mixed up The problem...
Hi all, we currently use the following packages: amqp-kafka-connector-0.11.5 and apache-qpid-jms-0.56 The sink connector (over amqp 1.0) itself works, but extremely slowly. What is immediately noticeable in the log is...
