projects
/
demos
/
kafka
/
outbox
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Moved the name of the header for the sequence-number into a static field
[demos/kafka/outbox]
/
delivery
/
src
/
main
/
java
/
de
/
juplo
/
kafka
/
outbox
/
delivery
/
OutboxProducer.java
diff --git
a/delivery/src/main/java/de/juplo/kafka/outbox/delivery/OutboxProducer.java
b/delivery/src/main/java/de/juplo/kafka/outbox/delivery/OutboxProducer.java
index
09c8789
..
2ad4b7e
100644
(file)
--- a/
delivery/src/main/java/de/juplo/kafka/outbox/delivery/OutboxProducer.java
+++ b/
delivery/src/main/java/de/juplo/kafka/outbox/delivery/OutboxProducer.java
@@
-25,6
+25,7
@@
public class OutboxProducer
{
final static Logger LOG = LoggerFactory.getLogger(OutboxProducer.class);
{
final static Logger LOG = LoggerFactory.getLogger(OutboxProducer.class);
+ public final static String HEADER = "#";
private final OutboxRepository repository;
private final KafkaProducer<String, String> producer;
private final OutboxRepository repository;
private final KafkaProducer<String, String> producer;
@@
-68,7
+69,7
@@
public class OutboxProducer
new ProducerRecord<>(topic, item.getKey(), item.getValue());
sequenceNumber = item.getSequenceNumber();
new ProducerRecord<>(topic, item.getKey(), item.getValue());
sequenceNumber = item.getSequenceNumber();
- record.headers().add(
"SEQ#"
, Longs.toByteArray(sequenceNumber));
+ record.headers().add(
HEADER
, Longs.toByteArray(sequenceNumber));
producer.send(record, (metadata, e) ->
{
producer.send(record, (metadata, e) ->
{