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