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:
5c4b0d9
)
Funktionsunabhängiger Name für das erweiterte Interface RebalanceListener
sumup-adder--ohne--stored-offsets
author
Kai Moritz
<kai@juplo.de>
Fri, 2 Sep 2022 03:22:50 +0000
(
05:22
+0200)
committer
Kai Moritz
<kai@juplo.de>
Fri, 2 Sep 2022 03:31:23 +0000
(
05:31
+0200)
src/main/java/de/juplo/kafka/ApplicationRebalanceListener.java
patch
|
blob
|
history
src/main/java/de/juplo/kafka/CommittingConsumerRebalanceListener.java
[deleted file]
patch
|
blob
|
history
src/main/java/de/juplo/kafka/EndlessConsumer.java
patch
|
blob
|
history
src/main/java/de/juplo/kafka/RebalanceListener.java
[new file with mode: 0644]
patch
|
blob
src/test/java/de/juplo/kafka/GenericApplicationTests.java
patch
|
blob
|
history
diff --git
a/src/main/java/de/juplo/kafka/ApplicationRebalanceListener.java
b/src/main/java/de/juplo/kafka/ApplicationRebalanceListener.java
index
d319295
..
63d57df
100644
(file)
--- a/
src/main/java/de/juplo/kafka/ApplicationRebalanceListener.java
+++ b/
src/main/java/de/juplo/kafka/ApplicationRebalanceListener.java
@@
-10,7
+10,7
@@
import java.util.*;
@RequiredArgsConstructor
@Slf4j
@RequiredArgsConstructor
@Slf4j
-public class ApplicationRebalanceListener implements
CommittingConsumer
RebalanceListener
+public class ApplicationRebalanceListener implements RebalanceListener
{
private final ApplicationRecordHandler recordHandler;
private final AdderResults adderResults;
{
private final ApplicationRecordHandler recordHandler;
private final AdderResults adderResults;
diff --git
a/src/main/java/de/juplo/kafka/CommittingConsumerRebalanceListener.java
b/src/main/java/de/juplo/kafka/CommittingConsumerRebalanceListener.java
deleted file mode 100644
(file)
index
8aa92c0
..0000000
--- a/
src/main/java/de/juplo/kafka/CommittingConsumerRebalanceListener.java
+++ /dev/null
@@
-1,10
+0,0 @@
-package de.juplo.kafka;
-
-import org.apache.kafka.clients.consumer.ConsumerRebalanceListener;
-
-
-public interface CommittingConsumerRebalanceListener extends ConsumerRebalanceListener
-{
- void enableCommits();
- void disableCommits();
-}
diff --git
a/src/main/java/de/juplo/kafka/EndlessConsumer.java
b/src/main/java/de/juplo/kafka/EndlessConsumer.java
index
63fc10f
..
3ff479c
100644
(file)
--- a/
src/main/java/de/juplo/kafka/EndlessConsumer.java
+++ b/
src/main/java/de/juplo/kafka/EndlessConsumer.java
@@
-25,7
+25,7
@@
public class EndlessConsumer<K, V> implements Runnable
private final String id;
private final String topic;
private final Consumer<K, V> consumer;
private final String id;
private final String topic;
private final Consumer<K, V> consumer;
- private final
CommittingConsumer
RebalanceListener rebalanceListener;
+ private final RebalanceListener rebalanceListener;
private final RecordHandler<K, V> recordHandler;
private final Lock lock = new ReentrantLock();
private final RecordHandler<K, V> recordHandler;
private final Lock lock = new ReentrantLock();
diff --git a/src/main/java/de/juplo/kafka/RebalanceListener.java
b/src/main/java/de/juplo/kafka/RebalanceListener.java
new file mode 100644
(file)
index 0000000..
26f97aa
--- /dev/null
+++ b/
src/main/java/de/juplo/kafka/RebalanceListener.java
@@ -0,0
+1,10
@@
+package de.juplo.kafka;
+
+import org.apache.kafka.clients.consumer.ConsumerRebalanceListener;
+
+
+public interface RebalanceListener extends ConsumerRebalanceListener
+{
+ void enableCommits();
+ void disableCommits();
+}
diff --git
a/src/test/java/de/juplo/kafka/GenericApplicationTests.java
b/src/test/java/de/juplo/kafka/GenericApplicationTests.java
index
7335770
..
8124c81
100644
(file)
--- a/
src/test/java/de/juplo/kafka/GenericApplicationTests.java
+++ b/
src/test/java/de/juplo/kafka/GenericApplicationTests.java
@@
-66,7
+66,7
@@
abstract class GenericApplicationTests<K, V>
@Autowired
MongoProperties mongoProperties;
@Autowired
@Autowired
MongoProperties mongoProperties;
@Autowired
-
CommittingConsumer
RebalanceListener rebalanceListener;
+ RebalanceListener rebalanceListener;
@Autowired
RecordHandler<K, V> recordHandler;
@Autowired
RecordHandler<K, V> recordHandler;