我使用 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 和密码,我知道架构注册表存在并且可以访问,因为我看到同事访问没有问题。有什么想法吗?
看起来您使用的是代理 URL,而不是架构注册表的 URL。这是从您指定 9092 作为端口这一事实推测出来的,这通常用于代理。
您可以在 Confluence Cloud 上的 Stream Governance API 部分获取 URL 和基本身份验证密钥/秘密。请参阅屏幕截图。希望这就是您的全部问题......