Насмешливый опрос КафкиКонсюмер () JUnit

Question

Мне трудно понять, как издеваться над KafkaConsumer. Ниже приведена базовая c структура моего кода.

public void run() {
    ...
    try (KafkaConsumer<String, String> consumer = new KafkaConsumer<>(kafkaParams)) {
        consumer.subscribe(topic);
        ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(pollInterval));
        methodToProcessRecords();
        ...
    }
}

Я хочу сделать что-то вроде этого:

whenCreateNewConsumer().thenReturn(mockConsumer);
when(mockConsumer.poll()).thenReturn(mockConsumerRecords);

Answer 1

Мне трудно понять, как издеваться над KafkaConsumer

Использовать MockConsumer

---

В качестве альтернативы, не совсем понятно, от чего вы потребляете. Если вы хотите производить и потреблять, используйте Kafka Streams TopologyTestDriver