mongo-kafka
mongo-kafka copied to clipboard
Kafka 414
https://jira.mongodb.org/browse/KAFKA-414
Pardon me, I now understand that the issue is calling super.validate before we actually try to resolve the config. I think we should move the validate for both source and sink. I do not understand why we need in the evaluate function.
Pardon me, I now understand that the issue is calling super.validate before we actually try to resolve the config. I think we should move the validate for both source and sink. I do not understand why we need in the evaluate function.
As long as we are calling super.validate on the resolved configs, we should be good.
I think there can be other ways to transform unresolved configs to resolved configs . What I proposed is just one of them. Feel free to experiment to find a better solution. Thanks
This is added to a new pull request.