如何使用 KafkaTopical 访问 Confluence Cloud Schema Registry?

问题描述 投票:0回答:1

我使用 KafkaTopical UI (https://www.kafkatopical.com) 连接到 Confluence Cloud Schema Registry 时遇到错误。当我点击“测试架构注册表”时,屏幕截图中不断出现超时错误。对于我们尝试过的其他云提供商来说,它通常工作正常。

尝试连接到 Confluence Cloud Schema 时弹出窗口

完整错误:

feign.RetryableException: Read timed out executing GET https://pkc-l6wr6.europe-west2.gcp.confluent.cloud:9092/config/
    at feign.SynchronousMethodHandler.executeAndDecode(SynchronousMethodHandler.java:110)
    at feign.SynchronousMethodHandler.invoke(SynchronousMethodHandler.java:70)
    at feign.ReflectiveFeign$FeignInvocationHandler.invoke(ReflectiveFeign.java:99)
    at jdk.proxy4.$Proxy275.getGlobalCompatibilityLevel(Unknown Source)
    at com.certak.kafkatopical.logic.kafka.util.KafkaServicesValidation.validateSchemaRegistry(KafkaServicesValidation.java:98)
    at com.certak.kafkatopical.logic.kafka.kbwrapper.KafkaWrapperService.testSchemaRegistry(KafkaWrapperService.java:466)
    at com.certak.kafkatopical.gui.cluster.properties.ClusterPropertiesViewModel.lambda$testSchemaRegistry$7(ClusterPropertiesViewModel.java:132)
    at com.certak.kafkatopical.gui.cluster.properties.ClusterPropertiesViewModel.lambda$_testConnection$3(ClusterPropertiesViewModel.java:108)
    at com.certak.common.javafx.gui.util.BackgroundTask$1.call(BackgroundTask.java:51)
    at com.certak.common.javafx.gui.util.DefaultTaskExecutor$2.call(DefaultTaskExecutor.java:164)
    at javafx.concurrent.Task$TaskCallable.call(Task.java:1426)
    at java.util.concurrent.FutureTask.run(FutureTask.java:264)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
    at java.util.concurrent.FutureTask.run(FutureTask.java:264)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
    at java.lang.Thread.run(Thread.java:833)
    at com.oracle.svm.core.thread.PlatformThreads.threadStartRoutine(PlatformThreads.java:704)
    at com.oracle.svm.core.windows.WindowsPlatformThreads.osThreadStartRoutine(WindowsPlatformThreads.java:143)
Caused by: java.net.SocketTimeoutException: Read timed out
    at sun.nio.ch.NioSocketImpl.timedRead(NioSocketImpl.java:283)
    at sun.nio.ch.NioSocketImpl.implRead(NioSocketImpl.java:309)
    at sun.nio.ch.NioSocketImpl.read(NioSocketImpl.java:350)
    at sun.nio.ch.NioSocketImpl$1.read(NioSocketImpl.java:803)
    at java.net.Socket$SocketInputStream.read(Socket.java:966)
    at sun.security.ssl.SSLSocketInputRecord.read(SSLSocketInputRecord.java:478)
    at sun.security.ssl.SSLSocketInputRecord.readHeader(SSLSocketInputRecord.java:472)
    at sun.security.ssl.SSLSocketInputRecord.bytesInCompletePacket(SSLSocketInputRecord.java:70)
    at sun.security.ssl.SSLSocketImpl.readApplicationRecord(SSLSocketImpl.java:1460)
    at sun.security.ssl.SSLSocketImpl$AppInputStream.read(SSLSocketImpl.java:1064)
    at okio.InputStreamSource.read(JvmOkio.kt:93)
    at okio.AsyncTimeout$source$1.read(AsyncTimeout.kt:128)
    at okio.RealBufferedSource.indexOf(RealBufferedSource.kt:430)
    at okio.RealBufferedSource.readUtf8LineStrict(RealBufferedSource.kt:323)
    at okhttp3.internal.http1.HeadersReader.readLine(HeadersReader.kt:29)
    at okhttp3.internal.http1.Http1ExchangeCodec.readResponseHeaders(Http1ExchangeCodec.kt:180)
    at okhttp3.internal.connection.Exchange.readResponseHeaders(Exchange.kt:110)
    at okhttp3.internal.http.CallServerInterceptor.intercept(CallServerInterceptor.kt:93)
    at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.kt:109)
    at okhttp3.internal.connection.ConnectInterceptor.intercept(ConnectInterceptor.kt:34)
    at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.kt:109)
    at okhttp3.internal.cache.CacheInterceptor.intercept(CacheInterceptor.kt:95)
    at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.kt:109)
    at okhttp3.internal.http.BridgeInterceptor.intercept(BridgeInterceptor.kt:83)
    at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.kt:109)
    at okhttp3.internal.http.RetryAndFollowUpInterceptor.intercept(RetryAndFollowUpInterceptor.kt:76)
    at okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.kt:109)
    at okhttp3.internal.connection.RealCall.getResponseWithInterceptorChain$okhttp(RealCall.kt:201)
    at okhttp3.internal.connection.RealCall.execute(RealCall.kt:154)
    at feign.okhttp.OkHttpClient.execute(OkHttpClient.java:177)
    at feign.SynchronousMethodHandler.executeAndDecode(SynchronousMethodHandler.java:100)
    ... 18 more

我尝试使用正确的 apikey 和密码,我知道架构注册表存在并且可以访问,因为我看到同事访问没有问题。有什么想法吗?

apache-kafka confluent-schema-registry confluent-cloud
1个回答
0
投票

看起来您使用的是代理 URL,而不是架构注册表的 URL。这是从您指定 9092 作为端口这一事实推测出来的,这通常用于代理。

您可以在 Confluence Cloud 上的 Stream Governance API 部分获取 URL 和基本身份验证密钥/秘密。请参阅屏幕截图。希望这就是您的全部问题......

Confluence 云架构注册表

© www.soinside.com 2019 - 2024. All rights reserved.