From e92414d0080a9c85ab3c9eaa8bffbb5e2b5da73b Mon Sep 17 00:00:00 2001 From: Sverre H Huseby Date: Sat, 7 Oct 2023 15:56:18 +0200 Subject: [PATCH] rename variable --- .../k3alagexporter/itest/K3aLagExporterIT.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/src/test/java/no/statnett/k3alagexporter/itest/K3aLagExporterIT.java b/src/test/java/no/statnett/k3alagexporter/itest/K3aLagExporterIT.java index bcb256c..abbdbaf 100644 --- a/src/test/java/no/statnett/k3alagexporter/itest/K3aLagExporterIT.java +++ b/src/test/java/no/statnett/k3alagexporter/itest/K3aLagExporterIT.java @@ -35,7 +35,7 @@ public final class K3aLagExporterIT { - private static K3aEmbedded kafka; + private static K3aEmbedded broker; private static final String CLUSTER_NAME = "the-cluster"; private static final String TOPIC = "the-topic"; private static final String CONSUMER_GROUP_ID = "consumer-group"; @@ -45,13 +45,13 @@ public final class K3aLagExporterIT { @BeforeAll public static void beforeClass() { LogUtils.initLogging(); - kafka = new K3aEmbedded(); - kafka.start(); + broker = new K3aEmbedded(); + broker.start(); } @AfterAll public static void afterClass() { - kafka.stop(); + broker.stop(); } @Test @@ -149,7 +149,7 @@ public Map getMinimalConsumerConfig() { private Map getCommonConfig() { final Map map = new HashMap<>(); - map.put(CommonClientConfigs.BOOTSTRAP_SERVERS_CONFIG, kafka.getBootstrapServers()); + map.put(CommonClientConfigs.BOOTSTRAP_SERVERS_CONFIG, broker.getBootstrapServers()); return map; }