camel-kafka-connector

camel-kafka-connector copied to clipboard

Document how to run camel-kafka-connector in a docker image

5

Lets take some information from #95

oscerd

Ensure Kafka metadata is avaiable in Sink task as in a standalone Kafka Camel source

4

I was surprised I don't seem to be able to use the key, offset, partition and topic like I could when using Camel standalone. Maybe I'm missing something that 's...

jaapterwoerds

Custom kafkaconnetor class as CamelAws2s3SourceConnector

17

Hello, I have added a custom class extending CamelAws2S3SourceConnector for some custom work. Now trying to build the project and deploy it. It's giving me the following error I am...

ruchirvaninasdaq

camel.source.endpoint.exceptionHandler for the sftp connector not working as expected

3

I've implemented a custom exceptionHandler for experimenting purpose like below (which is pretty much the same with the LoggingExceptionHandler except I'm using System.out.println() and I've added a prefix for every...

m20b27

Camel AWS S3 source connector

17

Hello, I have some issue with AWS S3 Connector. Every file i saw twice (or more) in my Kafka cluster. It's the same topic, file name, Timestamp, etc. The only...

ShaniAvnaim

Use KafkaConnect instead of KafkaConnectS2I for Strimzi docs

1

Latest Strimzi doc says `KafkaConnectS2I` is deprecated. We should use `KafkaConnect` for our instructions using Strimzi. https://strimzi.io/docs/operators/master/using.html#assembly-kafka-connect-str > With the introduction of build configuration to the KafkaConnect resource, Strimzi can...

tadayosi

I think it would be nice to have the fallback mechanism for messages that doesn’t have headers inside them, this could be useful for cases where one needs to process...

Estebangpp

Hi is there any way to pass the query parameter to websocket server endpoint ? my websocket server required this parameter: client=radar_kafka&transform=terminal_names , but the kafka connect use it as...

arickbro

vertx websocket source kafka connector configuration

3

Hi I got this error when configuring the vertx websocket kafka connector https://camel.apache.org/camel-kafka-connector/latest/reference/connectors/camel-atmosphere-websocket-kafka-source-connector.html may I know whether I missing any jar file here ? ``` Caused by: org.apache.camel.FailedToCreateRouteException: Failed to...

arickbro

camel-influxdb-kafka-connector: InfluxDB Connector not usable

1

# Description Hey, I tried to use the ```camel-influxdb-kafka-connector``` via Strimzi and Kafka Connect. But as the Connection setup in the [Camel InfluxDB Component](https://camel.apache.org/components/latest/influxdb-component.html) doesnt happens via String parameters, but...

sonic-martin