projects
/
demos
/
kafka
/
training
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
| inline |
side by side
(parent:
dc838e6
)
Vorlage
author
Kai Moritz
<kai@juplo.de>
Sun, 3 Apr 2022 16:30:46 +0000
(18:30 +0200)
committer
Kai Moritz
<kai@juplo.de>
Wed, 3 Aug 2022 20:05:59 +0000
(22:05 +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
ac9a541
..
b89802b
100644
(file)
--- a/
src/main/java/de/juplo/kafka/RestProducer.java
+++ b/
src/main/java/de/juplo/kafka/RestProducer.java
@@
-53,12
+53,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) ->
{