refactor: inline methods

statnett · Oct 24, 2023 · 590828b · 590828b
1 parent 9f29c9d
commit 590828b
Showing 1 changed file with 2 additions and 10 deletions.
diff --git a/src/test/java/no/statnett/k3alagexporter/itest/K3aLagExporterIT.java b/src/test/java/no/statnett/k3alagexporter/itest/K3aLagExporterIT.java
@@ -55,8 +55,8 @@ public void shouldDetectLag() {
         lagCollector = new ClusterLagCollector(CLUSTER_NAME,
                                                null, null, null, null,
                                                getMinimalConsumerConfig(), getMinimalAdminConfig());
-        try (final Producer<Integer, String> producer = getProducer()) {
-            try (final Consumer<Integer, String> consumer = getConsumer(CONSUMER_GROUP_ID)) {
+        try (final Producer<Integer, String> producer = new KafkaProducer<>(K3aTestUtils.producerProps(broker))) {
+            try (final Consumer<Integer, String> consumer = new KafkaConsumer<>(K3aTestUtils.consumerProps(CONSUMER_GROUP_ID, false, broker))) {
                 consumer.subscribe(Collections.singleton(TOPIC));
                 produce(producer);
                 int consumedValue = consume(consumer);
@@ -110,14 +110,6 @@ private int consume(final Consumer<Integer, String> consumer) {
         return lastValue;
     }
 
-    public Producer<Integer, String> getProducer() {
-        return new KafkaProducer<>(K3aTestUtils.producerProps(broker));
-    }
-
-    public Consumer<Integer, String> getConsumer(final String consumerGroupId) {
-        return new KafkaConsumer<>(K3aTestUtils.consumerProps(consumerGroupId, false, broker));
-    }
-
     public Map<String, Object> getMinimalAdminConfig() {
         return getCommonConfig();
     }