revert client builder

navikt · Feb 2, 2022 · 033dec1 · 033dec1
1 parent 7c83fcc
commit 033dec1
Showing 1 changed file with 2 additions and 11 deletions.
diff --git a/backend/src/main/kotlin/no/nav/mulighetsrommet/api/kafka/KafkaFactory.kt b/backend/src/main/kotlin/no/nav/mulighetsrommet/api/kafka/KafkaFactory.kt
@@ -6,6 +6,7 @@ import no.nav.common.kafka.consumer.KafkaConsumerClient
 import no.nav.common.kafka.consumer.util.KafkaConsumerClientBuilder
 import no.nav.common.kafka.consumer.util.deserializer.Deserializers.stringDeserializer
 import no.nav.common.kafka.util.KafkaPropertiesBuilder
+import no.nav.common.kafka.util.KafkaPropertiesPreset
 import no.nav.mulighetsrommet.api.database.DatabaseFactory
 import org.apache.kafka.clients.consumer.ConsumerRecord
 import org.apache.kafka.common.serialization.ByteArrayDeserializer
@@ -49,17 +50,7 @@ class KafkaFactory(private val db: DatabaseFactory) {
                 .withDeserializers(ByteArrayDeserializer::class.java, ByteArrayDeserializer::class.java)
                 .build()
         } else {
-            // KafkaPropertiesPreset.aivenDefaultConsumerProperties(consumerGroupId)
-            KafkaPropertiesBuilder.consumerBuilder()
-                .withBaseProperties(1)
-                .withConsumerGroupId(consumerGroupId)
-                .withAivenBrokerUrl()
-                .withAivenAuth()
-                .withDeserializers(
-                    ByteArrayDeserializer::class.java,
-                    ByteArrayDeserializer::class.java
-                )
-                .build()
+            KafkaPropertiesPreset.aivenDefaultConsumerProperties(consumerGroupId)
         }
     }