projects
/
demos
/
kafka
/
training
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Benennung vereinheitlicht und projektunabhängig gemacht
[demos/kafka/training]
/
src
/
test
/
java
/
de
/
juplo
/
kafka
/
ApplicationTests.java
diff --git
a/src/test/java/de/juplo/kafka/ApplicationTests.java
b/src/test/java/de/juplo/kafka/ApplicationTests.java
index
5b13b7d
..
d7eb039
100644
(file)
--- a/
src/test/java/de/juplo/kafka/ApplicationTests.java
+++ b/
src/test/java/de/juplo/kafka/ApplicationTests.java
@@
-65,9
+65,9
@@
class ApplicationTests
@Autowired
ExecutorService executor;
@Autowired
@Autowired
ExecutorService executor;
@Autowired
-
KeyCountingRebalanceListener keyCountingR
ebalanceListener;
+
ApplicationRebalanceListener r
ebalanceListener;
@Autowired
@Autowired
-
KeyCountingRecordHandler keyCountingR
ecordHandler;
+
ApplicationRecordHandler r
ecordHandler;
EndlessConsumer<String, Long> endlessConsumer;
Map<TopicPartition, Long> oldOffsets;
EndlessConsumer<String, Long> endlessConsumer;
Map<TopicPartition, Long> oldOffsets;
@@
-270,7
+270,7
@@
class ApplicationTests
});
TestRecordHandler<String, Long> captureOffsetAndExecuteTestHandler =
});
TestRecordHandler<String, Long> captureOffsetAndExecuteTestHandler =
- new TestRecordHandler<String, Long>(
keyCountingR
ecordHandler) {
+ new TestRecordHandler<String, Long>(
r
ecordHandler) {
@Override
public void onNewRecord(ConsumerRecord<String, Long> record)
{
@Override
public void onNewRecord(ConsumerRecord<String, Long> record)
{
@@
-287,7
+287,7
@@
class ApplicationTests
properties.getClientId(),
properties.getTopic(),
kafkaConsumer,
properties.getClientId(),
properties.getTopic(),
kafkaConsumer,
-
keyCountingR
ebalanceListener,
+
r
ebalanceListener,
captureOffsetAndExecuteTestHandler);
endlessConsumer.start();
captureOffsetAndExecuteTestHandler);
endlessConsumer.start();