camel-kafka-connector
camel-kafka-connector copied to clipboard
apache
Camel Kafka Connector allows you to use all Camel components as Kafka Connect connectors
https://github.com/jboss-fuse/camel-kafka-connector/blob/master/core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java#L100
There is this [//TODO](https://github.com/apache/camel-kafka-connector/blob/master/tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/GenerateCamelKafkaConnectorsMojo.java#L112) in the code ad a reminder to reason over if there is a way to include `dataformats` dependencies into the generated connectors and how.
See: https://github.com/apache/camel-kafka-connector/blob/master/tooling/camel-kafka-connector-generator-maven-plugin/README.adoc#L3
If the user has custom Camel Processor, IMHO it will be nice to bridge them into Kafka Connect as an SMT wrapper, where the user will just add the Processor...
It will be nice if we can somehow bridge between whetever we have for Camel DataFormat and bridge it as Kafka SMT (Single Message Transformation). However, my gut feelings is...
In similar way to https://github.com/apache/camel-kafka-connector/issues/16, this can be done to kafka connect converter. Ideally, this should be a thin wrapper around the transformer that being done https://github.com/apache/camel-kafka-connector/issues/16 with the condition...
Bumps [checkstyle](https://github.com/checkstyle/checkstyle) from 8.26 to 8.29. Release notes Sourced from checkstyle's releases. checkstyle-8.29 https://checkstyle.org/releasenotes.html#Release_8.29 checkstyle-8.28 https://checkstyle.org/releasenotes.html#Release_8.28 checkstyle-8.27 https://checkstyle.org/releasenotes.html#Release_8.27 Commits 8933d03 [maven-release-plugin] prepare release checkstyle-8.29 bd45909 Issue #7487: refactor code to...
![dependabot[bot] avatar](https://avatars.githubusercontent.com/in/29110?v=4 "dependabot[bot] avatar"){kind=avatar}
Fixed handling `SinkRecord` headers without schema.
`CamelSinkTask` is throwing `NullPointerException` during `SinkRecord` header mapping: > Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted. Error: null >...