skywalking引入kafka-report包,ui界面找不到服务实例

A服务引入skywalking,并在plugins目录下添加kafka-report的jar包,在A服务启动后,本地部署的skywalking的ui界面无法找到服务实例及数据,远程的kafka能够接收到数据。排除kafka-report包后,skywalking的ui界面能找到A服务及数据。本地的skywalking是接入的ES存储,为什么引入kafka-report的jar包后会出现这种情况,是哪里的配置没对吗?感觉走了kafka本地的ES存储就没了。

当skywalking中配置kafka fecher去消费kafka后,提示这个org.apache.kafka.common.errors.DisconnectException: Cancelled fetchMetadata request with correlation id 71 due to node -1 being disconnected,导致skwalking的ui没有数据,我的配置如下:

    kafka-fetcher:
      selector: ${SW_KAFKA_FETCHER:default}
      default:
        bootstrapServers: ${SW_KAFKA_FETCHER_SERVERS:127.0.0.1:8080}
        partitions: ${SW_KAFKA_FETCHER_PARTITIONS:3}
        replicationFactor: ${SW_KAFKA_FETCHER_PARTITIONS_FACTOR:2}
        enableNativeProtoLog: ${SW_KAFKA_FETCHER_ENABLE_NATIVE_PROTO_LOG:true}
        enableNativeJsonLog: ${SW_KAFKA_FETCHER_ENABLE_NATIVE_JSON_LOG:true}
        isSharding: ${SW_KAFKA_FETCHER_IS_SHARDING:false}
        consumePartitions: ${SW_KAFKA_FETCHER_CONSUME_PARTITIONS:""}
        kafkaHandlerThreadPoolSize: ${SW_KAFKA_HANDLER_THREAD_POOL_SIZE:-1}
        kafkaHandlerThreadPoolQueueSize: ${SW_KAFKA_HANDLER_THREAD_POOL_QUEUE_SIZE:-1}
        //官网没找到关于认证相关的配置,加了如下的配置,不知道是否支持这样配置
        security.protocol: SASL_PLAINTEXT
        sasl.mechanism: SCRAM-SHA-256
        sasl.jaas.config: org.apache.kafka.common.security.plain.PlainLoginModule required username="user" password="password"

引用 皆我百晓生 小程序回复内容作答:
根据您的描述,引入kafka-report包后,本地部署的skywalking的ui界面无法找到服务实例及数据。这可能是由于配置问题导致的。请确保以下几点:

  1. 确保skywalking的ui界面能够访问kafka服务。您可以检查kafka服务是否已正确启动,以及ui界面的配置文件中是否正确指定了kafka服务的地址和端口。

  2. 确保A服务正确连接到kafka服务并发送数据。您可以检查A服务的日志文件,查看是否有关于kafka的连接和数据发送的记录,以及确保A服务的配置文件中正确指定了kafka服务的地址和端口。

  3. 确保skywalking的ui界面正确连接到ES存储。您可以检查ui界面的配置文件中是否正确指定了ES存储的地址和端口。

  4. 检查A服务的skywalking配置文件中是否有关于kafka-report的配置项。您可以查看skywalking的官方文档,了解如何正确配置kafka-report。

如果您确定以上几点都没有问题,请检查skywalking的日志文件,查看是否有任何与kafka-report相关的错误或警告信息。这将有助于进一步排查问题。

总之,要解决问题,您需要仔细检查所有的配置,并确保每个组件都正确连接和配置。如果问题仍然存在,请提供更多详细信息,我们会尽力帮助您解决问题。