diff --git a/integrasjon/kafka-properties/src/main/java/no/nav/vedtak/felles/integrasjon/kafka/KafkaSender.java b/integrasjon/kafka-properties/src/main/java/no/nav/vedtak/felles/integrasjon/kafka/KafkaSender.java index 696d91ecc..07c10f7d1 100644 --- a/integrasjon/kafka-properties/src/main/java/no/nav/vedtak/felles/integrasjon/kafka/KafkaSender.java +++ b/integrasjon/kafka-properties/src/main/java/no/nav/vedtak/felles/integrasjon/kafka/KafkaSender.java @@ -10,18 +10,22 @@ public class KafkaSender { private final Producer 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) {