Error reading field 'leader' #1010
Description
- 我已经在 issues 搜索过相关问题了,并没有重复的。
你是否希望来认领这个Bug。
「 Y 」
环境信息
- KnowStreaming version : latest
- Operating System version : docker
- Java version : 1.8
- Confluent version : 7.0.1
- Kafka version : 3.0.x
重现该问题的步骤
-
下載docker-compose.yml文件,修改ui映射端口為8080:80
-
docker-compose up -d
预期结果
可以查看集群相關信息,log不報錯
实际结果
可以查看集群相關信息,log報錯
如果有异常，请附上异常Trace:
2023-05-09 11:32:24 2023-05-09 11:32:24.741 ERROR 12 --- [skTP-5-thread-3] c.x.k.s.km.common.utils.FutureWaitUtil : method=stepWaitResult||taskName=class=ClusterMetricCollector||clusterPhyId=1||metricName=BytesIn||errMsg=exception
2023-05-09 11:32:24
2023-05-09 11:32:24 java.util.concurrent.TimeoutException: null
2023-05-09 11:32:24 at java.util.concurrent.FutureTask.get(FutureTask.java:205)
2023-05-09 11:32:24 at com.xiaojukeji.know.streaming.km.common.utils.FutureWaitUtil.stepWaitResult(FutureWaitUtil.java:155)
2023-05-09 11:32:24 at com.xiaojukeji.know.streaming.km.common.utils.FutureWaitUtil.waitResult(FutureWaitUtil.java:116)
2023-05-09 11:32:24 at com.xiaojukeji.know.streaming.km.common.utils.FutureWaitUtil.waitExecute(FutureWaitUtil.java:76)
2023-05-09 11:32:24 at com.xiaojukeji.know.streaming.km.collector.metric.kafka.ClusterMetricCollector.collectKafkaMetrics(ClusterMetricCollector.java:74)
2023-05-09 11:32:24 at com.xiaojukeji.know.streaming.km.collector.metric.kafka.AbstractKafkaMetricCollector.collectMetrics(AbstractKafkaMetricCollector.java:37)
2023-05-09 11:32:24 at com.xiaojukeji.know.streaming.km.task.kafka.metrics.ClusterMetricCollectorTask.processClusterTask(ClusterMetricCollectorTask.java:25)
2023-05-09 11:32:24 at com.xiaojukeji.know.streaming.km.task.kafka.metrics.AbstractAsyncMetricsDispatchTask.lambda$asyncProcessSubTask$0(AbstractAsyncMetricsDispatchTask.java:33)
2023-05-09 11:32:24 at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
2023-05-09 11:32:24 at java.util.concurrent.FutureTask.run(FutureTask.java:266)
2023-05-09 11:32:24 at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
2023-05-09 11:32:24 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
2023-05-09 11:32:24 at java.lang.Thread.run(Thread.java:745)
2023-05-09 11:32:24
2023-05-09 11:32:24 2023-05-09 11:32:24.741 ERROR 12 --- [skTP-5-thread-3] c.x.k.s.km.common.utils.FutureWaitUtil : method=waitExecute||taskName=class=ClusterMetricCollector||clusterPhyId=1||metricName=BytesIn||msg=cancel task
2023-05-09 11:32:25 2023-05-09 11:32:25.600 ERROR 12 --- [kTP-6-thread-27] c.x.k.s.k.c.s.g.impl.GroupServiceImpl : method=getGroupDescription||clusterPhyId=1|groupName=schema-registry||errMsg=exception!
2023-05-09 11:32:25
2023-05-09 11:32:25 java.util.concurrent.ExecutionException: org.apache.kafka.common.protocol.types.SchemaException: Error reading field 'leader': Error reading string of length 29295, only 194 bytes available
2023-05-09 11:32:25 at org.apache.kafka.common.internals.KafkaFutureImpl.wrapAndThrow(KafkaFutureImpl.java:45)
2023-05-09 11:32:25 at org.apache.kafka.common.internals.KafkaFutureImpl.access$000(KafkaFutureImpl.java:32)
2023-05-09 11:32:25 at org.apache.kafka.common.internals.KafkaFutureImpl$SingleWaiter.await(KafkaFutureImpl.java:89)
2023-05-09 11:32:25 at org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:260)
2023-05-09 11:32:25 at com.xiaojukeji.know.streaming.km.core.service.group.impl.GroupServiceImpl.getGroupDescriptionFromKafka(GroupServiceImpl.java:188)
2023-05-09 11:32:25 at com.xiaojukeji.know.streaming.km.core.service.group.impl.GroupServiceImpl.getGroupFromKafka(GroupServiceImpl.java:112)
2023-05-09 11:32:25 at com.xiaojukeji.know.streaming.km.task.kafka.metadata.SyncKafkaGroupTask.processClusterTask(SyncKafkaGroupTask.java:45)
2023-05-09 11:32:25 at com.xiaojukeji.know.streaming.km.task.kafka.metadata.AbstractAsyncMetadataDispatchTask.lambda$asyncProcessSubTask$0(AbstractAsyncMetadataDispatchTask.java:33)
2023-05-09 11:32:25 at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
2023-05-09 11:32:25 at java.util.concurrent.FutureTask.run(FutureTask.java:266)
2023-05-09 11:32:25 at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
2023-05-09 11:32:25 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
2023-05-09 11:32:25 at java.lang.Thread.run(Thread.java:745)
2023-05-09 11:32:25 Caused by: org.apache.kafka.common.protocol.types.SchemaException: Error reading field 'leader': Error reading string of length 29295, only 194 bytes available
2023-05-09 11:32:25 at org.apache.kafka.common.protocol.types.Schema.read(Schema.java:118)
2023-05-09 11:32:25 at org.apache.kafka.connect.runtime.distributed.ConnectProtocol.deserializeAssignment(ConnectProtocol.java:217)
2023-05-09 11:32:25 at com.xiaojukeji.know.streaming.km.common.utils.kafka.KSPartialKafkaAdminClient$2.handleResponse(KSPartialKafkaAdminClient.java:1346)
2023-05-09 11:32:25 at com.xiaojukeji.know.streaming.km.common.utils.kafka.KSPartialKafkaAdminClient$AdminClientRunnable.handleResponses(KSPartialKafkaAdminClient.java:944)
2023-05-09 11:32:25 at com.xiaojukeji.know.streaming.km.common.utils.kafka.KSPartialKafkaAdminClient$AdminClientRunnable.processRequests(KSPartialKafkaAdminClient.java:1096)
2023-05-09 11:32:25 at com.xiaojukeji.know.streaming.km.common.utils.kafka.KSPartialKafkaAdminClient$AdminClientRunnable.run(KSPartialKafkaAdminClient.java:1019)
2023-05-09 11:32:25 ... 1 common frames omitted