search

smartloli / EFAK

A easy and high-performance monitoring system, for comprehensive monitoring and management of kafka cluster.
https://www.kafka-eagle.org/
Apache License 2.0
3.08k stars 778 forks source link

EFAk-3.0.1版本，我采用的mysql数据库，库名为默认的ke，但报错不能找到数据库cluster1的表 #702

Open RichardXu186 opened 6 months ago

RichardXu186 commented 6 months ago

EFAk-3.0.1版本，我采用的mysql数据库，库名为默认的ke，但报错不能找到数据库cluster1的表，具体报错日志信息如下： KafkaSchemaFactory.Thread-16068 - ERROR - Failure while loading table names for database 'cluster1': {} java.lang.NullPointerException at java.util.Hashtable.put(Hashtable.java:460) at org.smartloli.kafka.eagle.common.util.kraft.KafkaStoragePlugin.sasl(KafkaStoragePlugin.java:116) at org.smartloli.kafka.eagle.common.util.kraft.KafkaStoragePlugin.getKafkaConsumerProps(KafkaStoragePlugin.java:100) at org.smartloli.kafka.eagle.common.util.kraft.KafkaSchemaFactory.getTableNames(KafkaSchemaFactory.java:62) at org.smartloli.kafka.eagle.core.factory.v2.BrokerServiceImpl.topicList(BrokerServiceImpl.java:370) at org.smartloli.kafka.eagle.web.quartz.shard.task.sub.TopicThroughputByteInTask.throughput(TopicThroughputByteInTask.java:8 6) at org.smartloli.kafka.eagle.web.quartz.shard.task.sub.TopicThroughputByteInTask.run(TopicThroughputByteInTask.java:68) [2024-04-09 08:35:00] KafkaSchemaFactory.Thread-16067 - ERROR - Failure while loading table names for database 'cluster1': {} java.lang.NullPointerException at java.util.Hashtable.put(Hashtable.java:460) at org.smartloli.kafka.eagle.common.util.kraft.KafkaStoragePlugin.sasl(KafkaStoragePlugin.java:116) at org.smartloli.kafka.eagle.common.util.kraft.KafkaStoragePlugin.getKafkaConsumerProps(KafkaStoragePlugin.java:100) at org.smartloli.kafka.eagle.common.util.kraft.KafkaSchemaFactory.getTableNames(KafkaSchemaFactory.java:62) at org.smartloli.kafka.eagle.core.factory.v2.BrokerServiceImpl.topicList(BrokerServiceImpl.java:370) at org.smartloli.kafka.eagle.web.quartz.shard.task.sub.TopicThroughputByteOutTask.throughput(TopicThroughputByteOutTask.java :86) at org.smartloli.kafka.eagle.web.quartz.shard.task.sub.TopicThroughputByteOutTask.run(TopicThroughputByteOutTask.java:68) [2024-04-09 08:35:00] TopicThroughputByteInTask.Thread-16068 - ERROR - Stats topic throughput has error, msg is java.lang.NullPointerException at java.util.ArrayList.addAll(ArrayList.java:583) at org.smartloli.kafka.eagle.core.factory.v2.BrokerServiceImpl.topicList(BrokerServiceImpl.java:370) at org.smartloli.kafka.eagle.web.quartz.shard.task.sub.TopicThroughputByteInTask.throughput(TopicThroughputByteInTask.java:8 6) at org.smartloli.kafka.eagle.web.quartz.shard.task.sub.TopicThroughputByteInTask.run(TopicThroughputByteInTask.java:68) [2024-04-09 08:35:00] BScreenConsumerSubTask.Thread-16076 - ERROR - Collector consumer topic data has error, msg is java.lang.NullPointerException 这里的cluster1数据库怎么来的？

RichardXu186 commented 6 months ago

补充说明下，mysql 库ke中表都创建成功，EFAK-3.0.1也能正常使用，只是其中一些信息，如broker数量、zookeeper数量，消费者数量显示为0，topic list时没有列出topic

laonin commented 4 months ago

解决了吗老哥

RichardXu186 commented 2 months ago

没解决

在 2024-06-09 11:27:12，"laonin" @.***> 写道：

解决了吗老哥

— Reply to this email directly, view it on GitHub, or unsubscribe. You are receiving this because you authored the thread.Message ID: @.***>