X-Git-Url: https://juplo.de/gitweb/?p=demos%2Fkafka%2Foutbox;a=blobdiff_plain;f=outbox%2Fsrc%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Foutbox%2FOutboxProducer.java;h=30bef964c1d08034f9c35b67dc7d22dbe670de16;hp=627ca0578fc3a41d78f90183b2669b388c5bf2c3;hb=bdc7b089e14ddc16f7e76f6a736b27b608e35ab4;hpb=ef81f7d7d56b67a2084d1a5d3f66c5a3db8fb796

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) ->
     {