projects
/
demos
/
kafka
/
training
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
(from parent 2:
0d99ee9
)
Merge der überarbeiteten Compose-Konfiguration (Branch 'headers')
headers-vorlage
headers--vorlage---lvm-2-tage
author
Kai Moritz
<kai@juplo.de>
Sun, 7 Aug 2022 14:01:43 +0000
(16:01 +0200)
committer
Kai Moritz
<kai@juplo.de>
Sun, 7 Aug 2022 14:01:43 +0000
(16:01 +0200)
src/main/java/de/juplo/kafka/RestProducer.java
patch
|
blob
|
history
diff --git
a/src/main/java/de/juplo/kafka/RestProducer.java
b/src/main/java/de/juplo/kafka/RestProducer.java
index
b430e35
..
2f2a1cb
100644
(file)
--- a/
src/main/java/de/juplo/kafka/RestProducer.java
+++ b/
src/main/java/de/juplo/kafka/RestProducer.java
@@
-63,11
+63,7
@@
public class RestProducer
value // Value
);
- record.headers().add("source", id.getBytes());
- if (correlationId != null)
- {
- record.headers().add("id", BigInteger.valueOf(correlationId).toByteArray());
- }
+ // TODO: Fügen Sie die Header zu der Nachricht hinzu
producer.send(record, (metadata, e) ->
{