SpringCloud sleuth 整合zipkin+kafka 链接报错

来源:8-4 SpringCloud Sleuth 整合 Zipkin 实现分布式链路跟踪、收集

Captain2021

2022-02-07

gateway 配置文件
kafka:
bootstrap-servers: 192.168.5.89:9092
producer:
retries: 3
consumer:
auto-offset-reset: latest
zipkin:
sender:
type: kafka # 默认是 web
base-url: http://192.168.5.89:9411/
链接报错信息:
java.net.UnknownHostException: centos
at java.net.InetAddress.getAllByName0(InetAddress.java:1281) ~[na:1.8.0_251]
at java.net.InetAddress.getAllByName(InetAddress.java:1193) ~[na:1.8.0_251]
at java.net.InetAddress.getAllByName(InetAddress.java:1127) ~[na:1.8.0_251]
at org.apache.kafka.clients.ClientUtils.resolve(ClientUtils.java:110) ~[kafka-clients-2.5.0.jar:na]
at org.apache.kafka.clients.ClusterConnectionStatesNodeConnectionState.currentAddress(ClusterConnectionStates.java:403) [kafka−clients−2.5.0.jar:na]atorg.apache.kafka.clients.ClusterConnectionStatesNodeConnectionState.currentAddress(ClusterConnectionStates.java:403) ~[kafka-clients-2.5.0.jar:na] at org.apache.kafka.clients.ClusterConnectionStatesNodeConnectionState.currentAddress(ClusterConnectionStates.java:403) [kafkaclients2.5.0.jar:na]atorg.apache.kafka.clients.ClusterConnectionStatesNodeConnectionState.access200(ClusterConnectionStates.java:363) [kafka−clients−2.5.0.jar:na]atorg.apache.kafka.clients.ClusterConnectionStates.currentAddress(ClusterConnectionStates.java:151) [kafka−clients−2.5.0.jar:na]atorg.apache.kafka.clients.NetworkClient.initiateConnect(NetworkClient.java:955)[kafka−clients−2.5.0.jar:na]atorg.apache.kafka.clients.NetworkClient.ready(NetworkClient.java:293)[kafka−clients−2.5.0.jar:na]atorg.apache.kafka.clients.admin.KafkaAdminClient200(ClusterConnectionStates.java:363) ~[kafka-clients-2.5.0.jar:na] at org.apache.kafka.clients.ClusterConnectionStates.currentAddress(ClusterConnectionStates.java:151) ~[kafka-clients-2.5.0.jar:na] at org.apache.kafka.clients.NetworkClient.initiateConnect(NetworkClient.java:955) [kafka-clients-2.5.0.jar:na] at org.apache.kafka.clients.NetworkClient.ready(NetworkClient.java:293) [kafka-clients-2.5.0.jar:na] at org.apache.kafka.clients.admin.KafkaAdminClient200(ClusterConnectionStates.java:363) [kafkaclients2.5.0.jar:na]atorg.apache.kafka.clients.ClusterConnectionStates.currentAddress(ClusterConnectionStates.java:151) [kafkaclients2.5.0.jar:na]atorg.apache.kafka.clients.NetworkClient.initiateConnect(NetworkClient.java:955)[kafkaclients2.5.0.jar:na]atorg.apache.kafka.clients.NetworkClient.ready(NetworkClient.java:293)[kafkaclients2.5.0.jar:na]atorg.apache.kafka.clients.admin.KafkaAdminClientAdminClientRunnable.sendEligibleCalls(KafkaAdminClient.java:1018) [kafka-clients-2.5.0.jar:na]
at org.apache.kafka.clients.admin.KafkaAdminClientAdminClientRunnable.processRequests(KafkaAdminClient.java:1260)[kafka−clients−2.5.0.jar:na]atorg.apache.kafka.clients.admin.KafkaAdminClientAdminClientRunnable.processRequests(KafkaAdminClient.java:1260) [kafka-clients-2.5.0.jar:na] at org.apache.kafka.clients.admin.KafkaAdminClientAdminClientRunnable.processRequests(KafkaAdminClient.java:1260)[kafkaclients2.5.0.jar:na]atorg.apache.kafka.clients.admin.KafkaAdminClientAdminClientRunnable.run(KafkaAdminClient.java:1203) [kafka-clients-2.5.0.jar:na]
at java.lang.Thread.run(Thread.java:748) [na:1.8.0_251]

写回答

3回答

张勤一

2022-02-07

同学你好:

    看这个报错,是连接不上 Kafka 导致的;我建议不要使用虚拟机,这会让你的网络变得复杂,直接使用本地机器上的 Kafka,使用 127.0.0.1 即可

1
0

jam1980

2023-04-06

kafa需要修改server.properties文件。

listeners=PLAINTEXT://服务器ip:9092

advertised.listeners=PLAINTEXT://服务器ip:9092


0
0

BillyWebber

2022-04-16

请问你解决了吗?我也遇到同样的问题,代码和老师的一样但还是显示连接不上

0
0

Spring Cloud / Alibaba 微服务架构实战

从架构设计到开发实践,手把手实现

1210 学习 · 674 问题

查看课程