X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2FGenericApplicationTests.java;fp=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2FGenericApplicationTests.java;h=e63c5cefbfe3fda838fb4c7de7b680c8cd8a48a2;hb=924fb13cf514f79d2b01206476c2dea8536c8d44;hp=8849317a013ebe731893f4fd7dbefa6fa85c88fd;hpb=3d56a3162806ba0293d1f0cb31da43453f68e643;p=demos%2Fkafka%2Ftraining

diff --git a/src/test/java/de/juplo/kafka/GenericApplicationTests.java b/src/test/java/de/juplo/kafka/GenericApplicationTests.java
index 8849317..e63c5ce 100644
--- a/src/test/java/de/juplo/kafka/GenericApplicationTests.java
+++ b/src/test/java/de/juplo/kafka/GenericApplicationTests.java
@@ -67,8 +67,6 @@ abstract class GenericApplicationTests<K, V>
 	@Autowired
 	MongoProperties mongoProperties;
 	@Autowired
-	ConsumerRebalanceListener rebalanceListener;
-	@Autowired
 	RecordHandler<K, V> recordHandler;
 
 	KafkaProducer<Bytes, Bytes> testRecordProducer;
@@ -376,7 +374,6 @@ abstract class GenericApplicationTests<K, V>
 						properties.getClientId(),
 						properties.getTopic(),
 						kafkaConsumer,
-						rebalanceListener,
 						captureOffsetAndExecuteTestHandler);
 
 		endlessConsumer.start();