Details
-
Bug
-
Resolution: Works as Designed
-
Critical - P2
-
None
-
None
-
None
-
None
Description
Getting error while trying to load custom post processor chain class in mongodb-kafka sink connector.
post.processor.chain=allianz.itmp.kafka.mongodb.sink.postprocessor.xml.XMLParserPostProcessor
xmlParserPostProcessor.attributeMappings=xml_request,parsedXmlRequest,xml_response,parsedXmlResponse
field.renamer.mapping=
key.projection.list=
key.projection.type=none
value.projection.list=
value.projection.type=none
document.id.strategy=com.mongodb.kafka.connect.sink.processor.id.strategy.ProvidedInValueStrategy
document.id.strategy.overwrite.existing=false
java.util.concurrent.ExecutionException: org.apache.kafka.connect.runtime.rest.errors.BadRequestException: Connector configuration is invalid and contains the following 1 error(s):
Invalid value [allianz.itmp.kafka.mongodb.sink.postprocessor.xml.XMLParserPostProcessor] for configuration post.processor.chain
You can also find the above list of errors at the endpoint `/connector-plugins/{connectorType}/config/validate`
at org.apache.kafka.connect.util.ConvertingFutureCallback.result(ConvertingFutureCallback.java:115)
at org.apache.kafka.connect.util.ConvertingFutureCallback.get(ConvertingFutureCallback.java:99)
at org.apache.kafka.connect.cli.ConnectStandalone.main(ConnectStandalone.java:118)
Caused by: org.apache.kafka.connect.runtime.rest.errors.BadRequestException: Connector configuration is invalid and contains the following 1 error(s):
Invalid value [allianz.itmp.kafka.mongodb.sink.postprocessor.xml.XMLParserPostProcessor] for configuration post.processor.chain
You can also find the above list of errors at the endpoint `/connector-plugins/{connectorType}/config/validate`