From f10a435b8f6b0d30a149b354a73f1e1e34a2d7cd Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Fri, 30 Oct 2020 11:57:01 +0100
Subject: [PATCH] Added Google Guava for byte-conversions

---
 outbox/pom.xml                                              | 6 ++++++
 .../src/main/java/de/juplo/kafka/outbox/OutboxProducer.java | 6 ++----
 2 files changed, 8 insertions(+), 4 deletions(-)

diff --git a/outbox/pom.xml b/outbox/pom.xml
index f904537..e8b48b6 100644
--- a/outbox/pom.xml
+++ b/outbox/pom.xml
@@ -21,6 +21,7 @@
 
   <properties>
     <java.version>11</java.version>
+    <guava.version>30.0-jre</guava.version>
   </properties>
 
   <dependencies>
@@ -40,6 +41,11 @@
       <groupId>org.projectlombok</groupId>
       <artifactId>lombok</artifactId>
     </dependency>
+    <dependency>
+      <groupId>com.google.guava</groupId>
+      <artifactId>guava</artifactId>
+      <version>${guava.version}</version>
+    </dependency>
     <dependency>
       <groupId>org.postgresql</groupId>
       <artifactId>postgresql</artifactId>
diff --git a/outbox/src/main/java/de/juplo/kafka/outbox/OutboxProducer.java b/outbox/src/main/java/de/juplo/kafka/outbox/OutboxProducer.java
index 627ca05..30bef96 100644
--- a/outbox/src/main/java/de/juplo/kafka/outbox/OutboxProducer.java
+++ b/outbox/src/main/java/de/juplo/kafka/outbox/OutboxProducer.java
@@ -1,8 +1,8 @@
 package de.juplo.kafka.outbox;
 
+import com.google.common.primitives.Longs;
 import org.apache.kafka.common.serialization.StringSerializer;
 
-import java.nio.ByteBuffer;
 import java.time.Duration;
 import java.util.List;
 import java.util.Properties;
@@ -64,9 +64,7 @@ public class OutboxProducer
         new ProducerRecord<>(topic, item.getKey(), item.getValue());
 
     sequenceNumber = item.getSequenceNumber();
-    ByteBuffer buffer = ByteBuffer.allocate(Long.BYTES);
-    buffer.putLong(item.getSequenceNumber());
-    record.headers().add("SEQ#", buffer.array());
+    record.headers().add("SEQ#", Longs.toByteArray(sequenceNumber));
 
     producer.send(record, (metadata, e) ->
     {
-- 
2.20.1