Skip to content

H
holmes
Commit 382faf5d authored by 黎博's avatar 黎博
Browse files
Options

kafka KAFKA_ADVERTISED_LISTENERS修改

parent 6a217d78
Hide whitespace changes
Inline Side-by-side
Showing with 2 additions and 1 deletion
src/main/java/cn/qg/holmes/service/k8s/K8sService.java
View file @ 382faf5d
...@@ -2287,7 +2287,8 @@ public class K8sService { ...@@ -2287,7 +2287,8 @@ public class K8sService {
try { try {
kafkaService = getServiceDetail(namespace, "kafka-" + namespace); kafkaService = getServiceDetail(namespace, "kafka-" + namespace);
if (kafkaService != null) { if (kafkaService != null) {
kafkaAdvertisedListeners = "PLAINTEXT://" + kafkaService.getSpec().getClusterIP() + ":" + String.valueOf(kafkaService.getSpec().getPorts().get(0).getNodePort()); // kafkaAdvertisedListeners = "PLAINTEXT://" + kafkaService.getSpec().getClusterIP() + ":" + String.valueOf(kafkaService.getSpec().getPorts().get(0).getNodePort());
kafkaAdvertisedListeners = "PLAINTEXT://172.17.5.5:" + String.valueOf(kafkaService.getSpec().getPorts().get(0).getNodePort());
break; break;
} }
Thread.currentThread().sleep(1000); Thread.currentThread().sleep(1000);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment