@Autowired
MongoProperties mongoProperties;
@Autowired
- ConsumerRebalanceListener rebalanceListener;
- @Autowired
RecordHandler<K, V> recordHandler;
KafkaProducer<Bytes, Bytes> testRecordProducer;
properties.getClientId(),
properties.getTopic(),
kafkaConsumer,
- rebalanceListener,
captureOffsetAndExecuteTestHandler);
endlessConsumer.start();