alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-2407 Explicitly exposing promethes metrics via service and route

Browse Source
This commit is contained in:
jcechace 2020-09-01 13:49:51 +02:00 committed by Jiri Pechanec
parent f74da055b8
commit 05c39275ed
1 changed files with 11 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
debezium-testing/debezium-testing-openshift/src/main/java/io/debezium/testing/openshift/tools/kafka/KafkaConnectController.java
View File

@ -53,6 +53,7 @@
*/
public class KafkaConnectController {
private static final Logger LOGGER = LoggerFactory.getLogger(KafkaConnectController.class);
private static final int METRICS_PORT = 9404;
private final OpenShiftClient ocp;
private final OkHttpClient http;
@ -65,6 +66,7 @@ public class KafkaConnectController {
private KafkaConnect kafkaConnect;
private Route apiRoute;
private Route metricsRoute;
private Service metricsService;
public KafkaConnectController(KafkaConnect kafkaConnect, OpenShiftClient ocp, OkHttpClient http, boolean useConnectorResources) {
this.kafkaConnect = kafkaConnect;
@ -155,12 +157,16 @@ public Route exposeApi() {
*/
public Route exposeMetrics() {
LOGGER.info("Exposing KafkaConnect metrics");
String name = kafkaConnect.getMetadata().getName() + "-connect-metrics";
String nameSvc = kafkaConnect.getMetadata().getName() + "-connect-api";
Service service = ocp.services().inNamespace(project).withName(nameSvc).get();
metricsRoute = ocpUtils
.createRoute(project, name, nameSvc, "tcp-prometheus", service.getMetadata().getLabels());
String namePort = "tcp-prometheus";
String name = kafkaConnect.getMetadata().getName() + "-connect-metrics";
String nameApiSvc = kafkaConnect.getMetadata().getName() + "-connect-api";
Service apiService = ocp.services().inNamespace(project).withName(nameApiSvc).get();
Map<String, String> selector = apiService.getSpec().getSelector();
Map<String, String> labels = apiService.getMetadata().getLabels();
metricsService = ocpUtils.createService(project, name, namePort, METRICS_PORT, selector, labels);
metricsRoute = ocpUtils.createRoute(project, name, name, namePort, labels);
httpUtils.awaitApi(getMetricsURL());
return metricsRoute;