Kafka Connect error when trying to use new custom Transforms

Kafka Connect
1

Hello,

I am getting following errors when i am trying to new connectors using custom transforms I have defined.

{“error_code”:400,“message”:"Connector configuration is invalid and contains the following 4 error(s):\nInvalid value org.test.kafka.connect.transforms.MultiTopicRouter for configuration transforms.multiTopicRouter.type: Class org.test.kafka.connect.transforms.MultiTopicRouter could not be found.\nInvalid value null for configuration transforms.multiTopicRouter.type: Not a Transformation…

I believe this is because the connect is not able to recognize the MultiTopicRouter as a plugin when loading my my custom plugin jar (verified via connect logs that jar loaded but no plugins are added).

My custom plogin repo contains 1 predicate & 1 transform to route to messages to multiple topics. The transform implements org.apache.kafka.connect.transforms.Transformation & predicate implements org.apache.kafka.connect.transforms.predicates.Predicate. I have added the path to both of these under META-INF/services/org.apache.kafka.connect.transforms.Transformation & META-INF/services/org.apache.kafka.connect.transforms.predicates.Predicate respectively.

What else I might be missing for connect to recognize my custom transform & predicate?

2

This topic was automatically closed 30 days after the last reply. New replies are no longer allowed.