在使用kafka(java代码)进行我的第一步时,我想为kafka producer创建一个简单的测试,在这里我可以模拟zoo keeper(这个实现看起来不错,但是我无法访问其中的一些类,特别是embeddedzookeper和testutils)。有什么想法吗?
zphenhs41#
您可以使用kafka测试工件:
<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测试可能会执行以下操作:
<dependency> <groupId>org.apache.curator</groupId> <version>2.3.2-SNAPSHOT</version> <artifactId>curator-test</artifactId> <scope>test</scope> </dependency>
ercv8c1e2#
可能是Kafka的资料。。请检查此处的embeddedzk和此处的utils。。这里提供全套服务看看有没有用
2条答案
按热度按时间zphenhs41#
您可以使用kafka测试工件:
如果您需要zookeeper的单独模拟,apache curator测试可能会执行以下操作:
ercv8c1e2#
可能是Kafka的资料。。请检查此处的embeddedzk和此处的utils。。
这里提供全套服务
看看有没有用