From 741e5fe2407be286ef3986fd8b7b6c93058999d0 Mon Sep 17 00:00:00 2001
From: haerong22 <haerong22@naver.com>
Date: Tue, 2 Aug 2022 01:24:17 +0900
Subject: [PATCH] #15 kafka : producer - key value producer

---
 .../src/main/java/ProducerWithKeyValue.java   | 19 +++++++++++++++++++
 1 file changed, 19 insertions(+)
 create mode 100644 kafka/kafka-producer/src/main/java/ProducerWithKeyValue.java

diff --git a/kafka/kafka-producer/src/main/java/ProducerWithKeyValue.java b/kafka/kafka-producer/src/main/java/ProducerWithKeyValue.java
new file mode 100644
index 00000000..607d004d
--- /dev/null
+++ b/kafka/kafka-producer/src/main/java/ProducerWithKeyValue.java
@@ -0,0 +1,19 @@
+import org.apache.kafka.clients.producer.KafkaProducer;
+import org.apache.kafka.clients.producer.ProducerConfig;
+import org.apache.kafka.clients.producer.ProducerRecord;
+import org.apache.kafka.common.serialization.StringSerializer;
+import java.util.Properties;
+
+public class ProducerWithKeyValue {
+
+    public static void main(String[] args) {
+        KafkaProducer<String, String> producer = KafkaConfig.setup();
+
+        ProducerRecord<String, String> record = new ProducerRecord<>(KafkaConfig.TOPIC_NAME, "key1", "value1");
+        producer.send(record);
+        ProducerRecord<String, String> record2 = new ProducerRecord<>(KafkaConfig.TOPIC_NAME, "key2", "value2");
+        producer.send(record2);
+        producer.flush();
+        producer.close();
+    }
+}