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

Question

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

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

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.faster xml .jackson.databind.ex c .MismatchedInputException: Невозможно десериализовать экземпляр java.lang.String из токена START_OBJECT в [Source: (org.glassfi sh .jersey.message.internal.ReaderInterceptorExecutor $ UnCloseableInputSt ); строка: 1, столбец: 1335] (через цепочку ссылок: java .util.LinkedHashMap ["targetConnector"]) на com.faster xml .jackson.databind.ex c .MismatchedInputException.from (MismatchedInputException. java: 59) на com.faster xml .jackson.databind.DeserializationContext.reportInputMismatch (DeserializationContext. java: 1442) на com.faster xml .jackson.databind.DeserializationContext.handleUnexpectedToken (DeserializationContext). : 1216) на com.faster xml .jackson.databind.DeserializationContext.handleUnexpectedToken (DeserializationContext. java: 1126) на com.faster xml .jackson.databind.deser.std.StringDeserializer.deserialize (StringDeserializer *. 1023 *: 63) на com.faster xml .jackson.databind.deser.std.StringDeserializer.deserialize (StringDeserializer. java: 10) на com.faster xml .jackson.databind.deser.std.MapDeserializer ._readAndBindStringKeyMap (MapDeserializer. java: 527) на com.faster xml .jackson.databind.deser.std.MapDeserializer.deserialize (MapDeserializer. java: 364) на ком .faster xml .jackson.databind.deser.std.MapDeserializer.deserialize (MapDeserializer. java: 29) в com.faster xml .jackson.databind.ObjectReader._bind (ObjectReader. java: 1682) в com.faster xml .jackson.databind.ObjectReader.readValue (ObjectReader. java: 977) в com.faster xml .jackson.jaxrs.base.ProviderBase.readFrom (ProviderBase. java: 814) в org.glassfi sh .jersey.message.internal.ReaderInterceptorExecutor $ TerminalReaderInterceptor.invokeReadFrom (ReaderInterceptorExecutor. java: 233) в org.glassfi sh .jersey.message.internal.ReaderInororororor java: 212) в org.glassfi sh .jersey.message.internal.ReaderInterceptorExecutor.proceed (ReaderInterceptorExecutor. java: 132) в org.glassfi sh .jersey.server.internal.MappableExceptionWrapperInadoror MappableExceptionWrapperInterceptor. java: 49) в org.glassfi sh .jersey.message.internal.ReaderInterceptorExecutor.proceed (ReaderInterce ptorExecutor. java: 132) в org.glassfi sh .jersey.message.internal.MessageBodyFactory.readFrom (MessageBodyFactory. java: 1067) в org.glassfi sh .jersey.message.internal.InboundMessageContext. readEntity (InboundMessageContext. java: 850) в org.glassfi sh .jersey.server.ContainerRequest.readEntity (ContainerRequest. java: 247) в org.glassfi sh .jersey.server.internal.inject. EntityParamValueParamProvider $ EntityValueSupplier.apply (EntityParamValueParamProvider. java: 73) в org.glassfi sh .jersey.server.internal.inject.EntityParamValueParamProvider * 56p. ** в org.glassfi sh .jersey.server.model.internal.JavaResourceMethodDispatcherProvider $ AbstractMethodParamInvoker.getParamValues ​​( JavaResourceMethodDispatcherProvider. java: 109) на org.glassfi sh .jersey.server.model.internal.JavaResourceMethodDispatcherProvider $ ResponseOutInvoker. doDispatch (JavaResourceMethodDispatcherProvider. java: 176) по адресу org.glassfi sh .jersey.server.model.internal.AbstractJavaResourceMethodDispatcher.dispatch (AbstractJavaResourceMethodDispatcher. javaf. 79.jpg *. 79). model.ResourceMethodInvoker.invoke (ResourceMethodInvoker. java: 469) в org.glassfi sh .jersey.server.model.ResourceMethodInvoker.apply (ResourceMethodInvoker. java: 391) в orgsey.jerf. server.model.ResourceMethodInvoker.apply (ResourceMethodInvoker. java: 80) по адресу org.glassfi sh .jersey.server.ServerRuntime $ 1.run (ServerRuntime. java: 253) по адресу org.glassfi sh .jersey .internal.Errors $ 1.call (Ошибки. java: 248) в org.glassfi sh .jersey.internal.Errors $ 1.call (Ошибки. java: 244) в org.glassfi sh .jersey .internal.Errors.process (Ошибки. java: 292) в org.glassfi sh .jersey.internal.Errors.process (Ошибки. java: 274) в org.glassfi sh .jersey.internal .Errors.process (Ошибки. java: 244) в org.glassfi sh .jersey.process.internal.RequestS cope.runInScope (RequestScope. java: 265) на org.glassfi sh .jersey.server.ServerRuntime.process (ServerRuntime. java: 232) на org.glassfi sh .jersey.server.ApplicationHandler. дескриптор (ApplicationHandler. java: 679) в org.glassfi sh .jersey.servlet.WebComponent.serviceImpl (WebComponent. java: 392) в org.glassfi sh .jersey.servlet.WebComponent.service ( WebComponent. java: 346) в org.glassfi sh .jersey.servlet.ServletContainer.service (ServletContainer. java: 365) в org.glassfi sh .jersey.servlet.ServletContainer.service (ServletContainer. java: 318) в org.glassfi sh .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: 233l) в org. jetty.server.session.SessionHandler.doHandle (SessionHandler. java: 1581) в org.eclipse. jetty.server.handler.ScopedHandler.nextHandle (ScopedHandler. java: 233) в org.eclipse.jetty.server.handler.ContextHandler.doHandle (ContextHandler. java: 1307) в org.eclipse.jetty.ser. handler.ScopedHandler.nextScope (ScopedHandler. java: 188) в org.eclipse.jetty.servlet.ServletHandler.doScope (ServletHandler. java: 482) в org.eclipse.jetty.server.session.ScopeH SessionHandler. java: 1549) в org.eclipse.jetty.server.handler.ScopedHandler.nextScope (ScopedHandler. java: 186) в org.eclipse.jetty.server.handler.ContextHandler.doScope (ContextHandler *. 11). *: 1204) в org.eclipse.jetty.server.handler.ScopedHandler.handle (ScopedHandler. java: 141) в org.eclipse.jetty.server.handler.ContextHandlerCollection.handle (ContextHandlerCollection. java: 22) в org.eclipse.jetty.server.handler.StatisticsHandler.handle (StatisticsHandler. java: 173) в org.eclipse.jetty.server.handler.HandlerWrapper.handle (HandlerWrapper. java: 127) в org.eclipse .jetty.server.Server.handle (Server. * 1 117 *: 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.io.FillInterest.fillable (FillInterest. java: 103) в org.eclipse.jetty.io. ChannelEndPoint $ 2.run (ChannelEndPoint. java: 117) в org.eclipse.jetty.util.thread.QueuedThreadPool.runJob (QueuedThreadPool. java: 782) в org.eclipse.jetty.util.thread.Qooled $ .run (QueuedThreadPool. java: 918) в java .lang.Thread.run (Тема. java: 748)

Answer 1

Из журналов, которыми вы поделились, кажется, что IBM EventStream не может соединиться через bootstrap Маршрут / Входящий URL:

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

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

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