From: Kai Moritz <kai@juplo.de>
Date: Sat, 30 Jan 2021 15:37:31 +0000 (+0100)
Subject: Replaced handwritten property-names by references
X-Git-Tag: part-1~4
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=ca44f2f7e67fb263660adf43f816e5ec98a5e567;p=demos%2Fkafka%2Foutbox

Replaced handwritten property-names by references
---

diff --git a/delivery/src/main/java/de/juplo/kafka/outbox/delivery/OutboxProducer.java b/delivery/src/main/java/de/juplo/kafka/outbox/delivery/OutboxProducer.java
index ac7d4eb..999883f 100644
--- a/delivery/src/main/java/de/juplo/kafka/outbox/delivery/OutboxProducer.java
+++ b/delivery/src/main/java/de/juplo/kafka/outbox/delivery/OutboxProducer.java
@@ -17,6 +17,10 @@ import org.springframework.scheduling.annotation.Scheduled;
 
 import javax.annotation.PreDestroy;
 
+import static org.apache.kafka.clients.CommonClientConfigs.BOOTSTRAP_SERVERS_CONFIG;
+import static org.apache.kafka.clients.producer.ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG;
+import static org.apache.kafka.clients.producer.ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG;
+
 
 public class OutboxProducer
 {
@@ -41,9 +45,9 @@ public class OutboxProducer
     this.repository = repository;
 
     Properties props = new Properties();
-    props.put("bootstrap.servers", properties.bootstrapServers);
-    props.put("key.serializer", StringSerializer.class.getName());
-    props.put("value.serializer", StringSerializer.class.getName());
+    props.put(BOOTSTRAP_SERVERS_CONFIG, properties.bootstrapServers);
+    props.put(KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
+    props.put(VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
 
     this.producer = new KafkaProducer<>(props);
     this.topic = properties.topic;