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:
7eb2c86
)
Angleichungen zwischen Producer/Consumer
author
Kai Moritz
<kai@juplo.de>
Mon, 1 Aug 2022 21:07:55 +0000
(23:07 +0200)
committer
Kai Moritz
<kai@juplo.de>
Mon, 1 Aug 2022 21:14:01 +0000
(23:14 +0200)
src/main/java/de/juplo/kafka/SimpleProducer.java
patch
|
blob
|
history
diff --git
a/src/main/java/de/juplo/kafka/SimpleProducer.java
b/src/main/java/de/juplo/kafka/SimpleProducer.java
index
fd03d73
..
9fcaa6e
100644
(file)
--- a/
src/main/java/de/juplo/kafka/SimpleProducer.java
+++ b/
src/main/java/de/juplo/kafka/SimpleProducer.java
@@
-19,18
+19,18
@@
public class SimpleProducer
private volatile boolean running = true;
private volatile boolean done = false;
private volatile boolean running = true;
private volatile boolean done = false;
- public SimpleProducer(String broker, String topic, String
i
d)
+ public SimpleProducer(String broker, String topic, String
clientI
d)
{
Properties props = new Properties();
props.put("bootstrap.servers", broker);
{
Properties props = new Properties();
props.put("bootstrap.servers", broker);
- props.put("client.id",
i
d); // Nur zur Wiedererkennung
+ props.put("client.id",
clientI
d); // Nur zur Wiedererkennung
props.put("key.serializer", StringSerializer.class.getName());
props.put("value.serializer", StringSerializer.class.getName());
producer = new KafkaProducer<>(props);
this.topic = topic;
props.put("key.serializer", StringSerializer.class.getName());
props.put("value.serializer", StringSerializer.class.getName());
producer = new KafkaProducer<>(props);
this.topic = topic;
- this.id =
i
d;
+ this.id =
clientI
d;
}
public void run()
}
public void run()
@@
-124,14
+124,14
@@
public class SimpleProducer
broker = args[0];
}
broker = args[0];
}
- SimpleProducer
producer
= new SimpleProducer(broker, topic, clientId);
+ SimpleProducer
instance
= new SimpleProducer(broker, topic, clientId);
Runtime.getRuntime().addShutdownHook(new Thread(() ->
{
Runtime.getRuntime().addShutdownHook(new Thread(() ->
{
-
producer
.running = false;
- while (!
producer
.done)
+
instance
.running = false;
+ while (!
instance
.done)
{
{
- log.info("Waiting for
producer
...");
+ log.info("Waiting for
main-thread
...");
try
{
Thread.sleep(1000);
try
{
Thread.sleep(1000);
@@
-142,10
+142,10
@@
public class SimpleProducer
}));
log.info(
}));
log.info(
- "Running
simple p
roducer: broker={}, topic={}, client-id={}",
+ "Running
SimpleP
roducer: broker={}, topic={}, client-id={}",
broker,
topic,
clientId);
broker,
topic,
clientId);
-
producer
.run();
+
instance
.run();
}
}
}
}