import com.mongodb.client.MongoClient;
import lombok.extern.slf4j.Slf4j;
+import org.apache.kafka.clients.consumer.ConsumerRebalanceListener;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.apache.kafka.clients.consumer.KafkaConsumer;
import org.apache.kafka.clients.producer.KafkaProducer;
@Autowired
MongoProperties mongoProperties;
@Autowired
- CommittingConsumerRebalanceListener rebalanceListener;
- @Autowired
RecordHandler<K, V> recordHandler;
KafkaProducer<Bytes, Bytes> testRecordProducer;
properties.getClientId(),
properties.getTopic(),
kafkaConsumer,
- rebalanceListener,
captureOffsetAndExecuteTestHandler);
endlessConsumer.start();