[Bug] Kafka Connector failed to start #4690
Description
Search before asking
- I had searched in the issues and found no similar issues.
Environment
Windows
EventMesh version
master
What happened
Kafka Connector failed to start since #4180.
How to reproduce
run KafkaConnectServer.
It seems to be the problem of org.apache.eventmesh.connector.kafka.sink.config.SourceConnectorConfig#keyConverter.
Debug logs
2023-12-27 15:55:46,176 ERROR [main] Application(Application.java:59) - connector kafkaSource initialize error
org.apache.kafka.common.KafkaException: Failed to construct kafka consumer
at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:823) ~[kafka-clients-3.0.0.jar:?]
at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:664) ~[kafka-clients-3.0.0.jar:?]
at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:645) ~[kafka-clients-3.0.0.jar:?]
at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:625) ~[kafka-clients-3.0.0.jar:?]
at org.apache.eventmesh.connector.kafka.source.connector.KafkaSourceConnector.init(KafkaSourceConnector.java:66) ~[classes/:?]
at org.apache.eventmesh.openconnect.Application.run(Application.java:56) [classes/:?]
at org.apache.eventmesh.connector.kafka.server.KafkaConnectServer.main(KafkaConnectServer.java:38) [classes/:?]
Caused by: org.apache.kafka.common.KafkaException: class org.apache.kafka.common.serialization.StringSerializer is not an instance of org.apache.kafka.common.serialization.Deserializer
at org.apache.kafka.common.config.AbstractConfig.getConfiguredInstance(AbstractConfig.java:403) ~[kafka-clients-3.0.0.jar:?]
at org.apache.kafka.common.config.AbstractConfig.getConfiguredInstance(AbstractConfig.java:434) ~[kafka-clients-3.0.0.jar:?]
at org.apache.kafka.common.config.AbstractConfig.getConfiguredInstance(AbstractConfig.java:419) ~[kafka-clients-3.0.0.jar:?]
at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:708) ~[kafka-clients-3.0.0.jar:?]
... 6 more
Are you willing to submit PR?
- Yes I am willing to submit a PR!
Code of Conduct
- I agree to follow this project's Code of Conduct *