Kafka Connectors / question on general use of k8s connectors

[dberardo-com]

trafficstars

hi there,

I am not new to camel kafka connectors, and I am evaluating the kafka-kubernetes connectors from the public list: https://camel.apache.org/camel-kafka-connector/0.11.x/reference/index.html

there i can find these connectors:

what i might need is the sink connector, which i understand can be used to cretae kubernetes objects from kafka messages. Is my understanding correct?

is there any example out there on how to configure/use this connector? in particular when it comes to the .operation property?

Cheers

[squakez]

I've moved it under the proper project. Hope you can get better support here.

[dberardo-com]

thanks a lot, i could not find the proper project.

[dberardo-com]

i have come to understand that this connector was perhaps not meant to do what i was thinking of.

basically what i am looking for is a kafka sink connectors that translates messages into K8s objects using a specific service account.

sure enough this could be done with a http connector, but it would be a bit hacky because credentials for the sourceaccount should be pass in the configuration (insecure) and because if could become cumbersome to deal with nested jsons.

Would you recommend any other connector instead?