projects
/
demos
/
kafka
/
outbox
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Added Google Guava for byte-conversions
[demos/kafka/outbox]
/
outbox
/
src
/
main
/
java
/
de
/
juplo
/
kafka
/
outbox
/
OutboxProducer.java
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
(file)
--- 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;
package de.juplo.kafka.outbox;
+import com.google.common.primitives.Longs;
import org.apache.kafka.common.serialization.StringSerializer;
import org.apache.kafka.common.serialization.StringSerializer;
-import java.nio.ByteBuffer;
import java.time.Duration;
import java.util.List;
import java.util.Properties;
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();
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) ->
{
producer.send(record, (metadata, e) ->
{