0

我已经使用 Strimzi 在 Kubernetes 上配置了 Kafka。我尝试通过 MM2 将 Kafka 与 IBM EventStream 连接,但出现错误..

任何导致问题的消息和主题的想法

2020-03-09 17:25:40,258 错误 REST 调用 /connectors/my-cluster-source->my-cluster-target.MirrorSourceConnector/config (org.apache.kafka.connect.runtime.rest.errors .ConnectExceptionMapper)[qtp1584918772-17] com.fasterxml.jackson.databind.exc.MismatchedInputException:无法反序列化实例java.lang.String[来源:(org.glassfish.jersey.message.internal.ReaderInterceptorExecutor$UnCloseableInputStream)的START_OBJECT令牌;行:1,列:1335](通过参考链:java.util.LinkedHashMap["targetConnector"])在 com.fasterxml.jackson.databind.exc.MismatchedInputException.from(MismatchedInputException.java:59) 在 com.fasterxml。 jackson.databind.DeserializationContext.reportInputMismatch(DeserializationContext.java:1442) 在 com.fasterxml.jackson.databind.DeserializationContext.handleUnexpectedToken(DeserializationContext.java:1216) 在 com.fasterxml.jackson.databind.DeserializationContext.handleUnexpectedToken(DeserializationContext.java: 1126) 在 com.fasterxml.jackson.databind.deser.std 的 com.fasterxml.jackson.databind.deser.std.StringDeserializer.deserialize(StringDeserializer.java:63)。

4

1 回答 1

0

从您共享的日志看来,IBM EventStream 似乎无法通过引导路由/入口 url 连接:

org.apache.kafka.connect.runtime.rest.errors.ConnectExceptionMapper

所以我的建议是请检查您在 Kubernetes 上的 Ingress 配置,因为我想您正在尝试访问您的 Kubernetes 集群的 Strimzi 集群,并确保您可以从本地本地使用 Kafka 控制台消费者/生产者生产/消费消息,在 K8S 中访问您的 Kafka 集群。

如果您使用 https,请确保在路由/入口 url 末尾附加 443(或 8443)端口,并删除您在 IBM EventStream 配置中设置的“https://”作为引导服务器 url。

于 2020-03-09T21:06:09.587 回答