KafkaSender utility for å unngå lokale topics (#1352)

navikt · Mar 25, 2024 · e70699a · e70699a
1 parent d6860c3
commit e70699a
Showing 1 changed file with 9 additions and 5 deletions.
diff --git a/...on/kafka-properties/src/main/java/no/nav/vedtak/felles/integrasjon/kafka/KafkaSender.java b/...on/kafka-properties/src/main/java/no/nav/vedtak/felles/integrasjon/kafka/KafkaSender.java
@@ -10,18 +10,22 @@
 public class KafkaSender {
 
     private final Producer<String, String> producer;
-    private final String topic;
+    private final String topicName;
 
-    public KafkaSender(String topic) {
+    public KafkaSender(String topicName) {
         this.producer = new KafkaProducer<>(KafkaProperties.forProducer());
-        this.topic = topic;
+        this.topicName = topicName;
+    }
+
+    public String getTopicName() {
+        return topicName;
     }
 
     public RecordMetadata send(String key, String message) {
-        if (topic == null) {
+        if (topicName == null) {
             throw kafkaPubliseringException("null", new IllegalArgumentException());
         }
-        return send(key, message, this.topic);
+        return send(key, message, this.topicName);
     }
 
     public RecordMetadata send(String key, String message, String topic) {