Strimzi: MirrorMaker 2.0 подключается к IBM EventStream

Question

Я настроил Kafka на Kubernetes с помощью Strimzi. Я попытался подключить Kafka к IBM EventStream через MM2, но получаю ошибку..

Любые мысли, какое сообщение и тема вызывают проблемы

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из токена START_OBJECT в [Источник: (org.glassfish.jersey.message.internal.ReaderInterceptorExecutor$UnCloseableInputStream); строка: 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) at com.fasterxml.jackson.databind.DokenlerializationContext(DeserializationContext.1126) на com.fasterxml.jackson.databind.deser.std.StringDeserializer.deserialize(StringDeserializer.java:63) на com.fasterxml.jackson.databind.deser.std.StringDeserializer.deserialize(StringDeserializer.java:10) по адресу com.fasterxml.jackson.databind.deser.std.MapDeserializer._readAndBindStringKeyMap(MapDeserializer.java:527) по адресу com.fasterxml.jackson.java: MapDeserializer.java:364) в com.fasterxml.jackson.databind.deser.std.MapDeserializer.deserialize(MapDeserializer.java:29) в com.fasterxml.jackson.databind.ObjectReader._bind(ObjectReader.java:1682) в com..fasterxml.jackson.databind.ObjectReader.readValue(ObjectReader.java:977) в com.fasterxml.jackson.jaxrs.base.ProviderBase.readFrom(ProviderBase.java:814) в org.glassfish.jersey.message.internal.ReeaderInternal. $TerminalReaderInterceptor.invokeReadFrom(ReaderInterceptorExecutor.java:233) в org.glassfish.jersey.message.internal.ReaderInterceptorExecutor$TerminalReaderInterceptor.aroundReadFrom(ReaderInterceptorExecutor.java:212) в org.glassfish.jersey.message.internal.ReaderInterceptorExecutor.proceed (ReaderInterceptorExecutor.java:lassage.Executor.proceed (ReaderInterceptorExecutor.java:lasspper.ExecutorInterceptor.proceed (ReaderInterceptorExecutor.java:lasspper. java: 49) в org.glassfish.jersey.message.internal.ReaderInterceptorExecutor.proceed(ReaderInterceptorExecutor.java:132) в org.glassfish.jersey.message.internal.MessageBodyFactory.readFrom(MessageBody.glassfish) или.jersey.message.internal.InboundMessageContext.readEntity(InboundMessageContext.java:850) на org.glassfish.jersey.server.ContainerRequest.readEntity(ContainerRequest.java:247) на org.glassfish.jersey.server.internal.internal.EntityParamValueParamProvider$EntityValueSupplier.apply(EntityParamValueParamProvider.java:73) в org.glassfish.jersey.server.internal.inject.EntityParamValueParamProvider$EntityValueSupplier.ParamValueParamProvider $ EntityValueParamValueParamProvider $ EntityValueParamValueParamProvider $ EntityValueParamValueParamProvider (EntityValueParamValueParamProvider $ EntityValueParamValueParamProvider $ EntityValueParamValueProvider).ParamValueFactoryWithSource.apply(ParamValueFactoryWithSource.java:50) по адресу org.glassfish.jersey.server.spi.internal.ParameterValueHelper.getParameterValues ​​(ParameterValueHelper.javadavdata.javad.java.java.java.java.java.java.java.java.java. getParamValues ​​(JavaResourceMethodDispatcherProvider.java:109) в org.glassfish.jersey.server.model.internal.JavaResourceMethodDispatcherProvider$ResponseOutInvoker.doDispatch(JavaResourceMethodDispatcherProvider.java:109.internal.AbstractJavaResourceMethodDispatcher.dispatch(AbstractJavaResourceMethodDispatcher.java:79) по адресу org.glassfish.jersey.server.model.ResourceMethodInvoker.invoke(ResourceMethodInvoker.javamo:469) в org.glassfish.jersey.server.model.ResourceMethodInvoker.invoke(ResourceMethodInvoker.javamo:469.java:391) на org.glassfish.jersey.server.model.ResourceMethodInvoker.apply(ResourceMethodInvoker.java:80) на org.glassfish.jersey.server.ServerRuntime$1.run(ServerRuntime.java:253ass) на org.glassfish.jersey.internal.Errors$1.call(Errors.java:248) в org.glassfish.jersey.internal.Errors$1.call(Errors.java:244) в org.glassfish.jersey.internal.Errors.process(Errors.java:292) на org.glassfish.jersey.internal.Errors.process(Errors.java:274) на org.glassfish.jersey.internal.Errors.process(Errors.java:244) на org.glassfish.jersey.process.internal.RequestScope.runInScope(RequestScope.java:265) в org.glassfish.jersey.server.ServerRuntime.process(ServerRuntime.java:232) в org.glassfish.jersey.server.ApplicationHandler.handle(ApplicationHandler.java:679) на org.glassfish.jersey.servlet.WebComponent.serviceImpl(WebComponent.java:392) на org.glassfish.jersey.servlet.WebComponent.service(WebComponent.java:346) на org.glassfish.jersey.servlet.ServletContainer.service(ServletContainer.java:365) в org.glassfish.jersey.servlet.ServletContainer.service(ServletContainer.java:318) в org.glassfish.jersey.servlet.ServletContainer.service(ServletContainer.java:205) в org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:852) на org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:544) на org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233) в org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:1581) в org.eclipse.jetty.server.handler.ScopedHandler (.nextHandle) java: 233) в org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1307) в org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:188) в org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:482) на org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:1549) на org.eclipse.jetty.server.handler.ScopedHandler.next(ScopedHandler.java:186) в org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1204) в org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141) в орг.eclipse.jetty.server.handler.ContextHandlerCollection.handle(ContextHandlerCollection.java:221) в org.eclipse.jetty.server.handler.StatisticsHandler.handle(StatisticsHandler.java:173) в org.eclipse.jetty.server.handle.HandlerWrapper.handle(HandlerWrapper.java:127) в org.eclipse.jetty.server.Server.handle(Server.java:494) в org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:374) в org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:268) в org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:311) в org.eclipse.jetty.fillable(FillInterest.java:103) в org.eclipse.jetty.io.ChannelEndPoint$2.run(ChannelEndPoint.java:117) в org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.javag:782) в.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:918) в java.lang.Thread.run(Thread.java:748)

Answer 1

Из журналов, которыми вы поделились, кажется, что IBM EventStream не может подключиться через загрузочный URL-адрес Route/Ingress:

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

Поэтому я предлагаю проверить свою конфигурацию Ingress в Kubernetes, поскольку я полагаю, вы пытаетесь получить доступ к кластеру Strimzi нашего кластера Kubernetes и убедитесь, что вы можете создавать / потреблять сообщения с помощью потребителя / производителя консоли Kafka изначально из вашего локального, доступ к вашему кластеру Kafka в K8S.

Если вы используете https, обязательно добавьте порт 443 (или 8443) в конец URL-адреса маршрута / входа и удалите "https://" в качестве URL-адреса сервера начальной загрузки, который вы установили в конфигурации IBM EventStream.