projects
/
demos
/
kafka
/
training
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
(from parent 2:
ece4cdf
)
Merge der Überarbeitungen für die LVM-Schulung aus dem Branch 'customized'
customized-vorlage
customized--vorlage---lvm-2-tage
author
Kai Moritz
<kai@juplo.de>
Wed, 3 Aug 2022 20:06:07 +0000
(22:06 +0200)
committer
Kai Moritz
<kai@juplo.de>
Wed, 3 Aug 2022 20:06:07 +0000
(22:06 +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
b5bb2d9
..
2706313
100644
(file)
--- a/
src/main/java/de/juplo/kafka/RestProducer.java
+++ b/
src/main/java/de/juplo/kafka/RestProducer.java
@@
-55,12
+55,9
@@
public class RestProducer
final long time = System.currentTimeMillis();
- final ProducerRecord<String, String> record = new ProducerRecord<>(
- topic, // Topic
- partition, // Partition
- key, // Key
- value // Value
- );
+ // TODO: Nachricht an eine fixe Partition versenden, wenn partition != null
+ // Ansonsten wie bisher an eine über den Schlüssel gewählte
+ final ProducerRecord<String, String> record = null;
producer.send(record, (metadata, e) ->
{