kafka-connect-transform-common
kafka-connect-transform-common copied to clipboard
jcustenborder
Common Transforms for Kafka Connect.
I'm dumping a nested structure into MongoDB and I'd like to apply lowercase on all fieldnames, also the nested fields. The current ChangeCase transformation only applies to the first level...
I am making use of the HeaderToField to attempt to filter messages from a message's header. The message header I am making use of is added by replicator, the provenance...
I try to add this connector on kafka: ```` curl -X POST \ -H "Content-Type: application/json" \ --data ' {"name": "mongo-source-with-ts", "config": { "connector.class":"com.mongodb.kafka.connect.MongoSourceConnector", "connection.uri":"mongodb://localhost:27017", "topic.prefix":"myPrefix", "database":"test", "collection":"prep", "transforms" :...
Bumps xercesImpl from 2.12.1 to 2.12.2. [](https://docs.github.com/en/github/managing-security-vulnerabilities/about-dependabot-security-updates#about-compatibility-scores) Dependabot will resolve any conflicts with this PR as long as you don't alter it yourself. You can also trigger a...
![dependabot[bot] avatar](https://avatars.githubusercontent.com/in/29110?v=4 "dependabot[bot] avatar"){kind=avatar}
Hi, Latest version available in maven central is 0.1.0.14. Please publish newer/latest versions to Maven Central.
Hi, everyone. I'm using Kafka topics to send messages in avro schema format through S3 Sink connectors. Possibly I will use the HeaderToField$Value config in the connectors. Do you know...
Hi 👋 I'm using kafka topic to store messages with different avro schemas. Schema are stored within Confluent SR. I would like to send messages from the same topic to...
https://github.com/jcustenborder/kafka-connect-transform-common/blob/9126c92bbea21e75046541d0f41f737bca8b27de/src/main/java/com/github/jcustenborder/kafka/connect/transform/common/ExtractNestedField.java#L50
https://github.com/jcustenborder/kafka-connect-transform-common/blob/9126c92bbea21e75046541d0f41f737bca8b27de/src/main/java/com/github/jcustenborder/kafka/connect/transform/common/ExtractNestedField.java#L82