модульный тест производителя Кафки (java)

Делая свои первые шаги с kafka (java-код), я хотел бы создать простой тест для Kafka producer, что-то вроде this, где я могу издеваться над Zoo keeper (эта реализация выглядит хорошо, но я не могу достичь некоторых классов там, в частности EmbeddedZookeeper и TestUtils).

Есть идеи?

2 6
unit-testing apache-kafka apache-zookeeper

2 ответа:

Вы можете использовать артефакт теста Кафки: 

<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka_2.9.2</artifactId>
    <version>0.8.0</version>
    <classifier>test</classifier>
    <scope>test</scope>
</dependency>

Если вам нужен отдельный макет для zookeeper, Apache curator-test может сделать: 

<dependency>
    <groupId>org.apache.curator</groupId>
    <version>2.3.2-SNAPSHOT</version>
    <artifactId>curator-test</artifactId>
    <scope>test</scope>
</dependency>
7

Вероятно, взято из источника Кафки .. Проверьте здесь для EmbeddedZk и здесь для Utils ..

Полный пакет доступен здесь

Посмотрим, поможет ли это

1