我想用嵌入式Kafka测试我的处理器。有可能吗？当我用kafka&zk在本地运行应用程序时，它运行得非常好——我的示例侦听器接收到的消息与处理器相同（很好，两个侦听器都侦听相同的主题），但是当我用嵌入的kafka测试它时，只有用 @KafkaListener 获取消息，但处理器未获取任何内容。我想将消息发送到处理器的主题，然后检查它是否将结果发送到其他主题。对于这样的用例有什么解决方案吗？
@KafkaListener
quhf5bfb1#
建议使用 TopologyTestDriver : https://kafka.apache.org/11/documentation/streams/developer-guide/testing.html你也可以使用 KafkaEmbedded ，或者更好 EmbeddedKafkaCluster . 例如，请查看kafka streams集成测试：https://github.com/apache/kafka/tree/trunk/streams/src/test/java/org/apache/kafka/streams/integration
TopologyTestDriver
KafkaEmbedded
EmbeddedKafkaCluster
1条答案
按热度按时间quhf5bfb1#
建议使用
TopologyTestDriver: https://kafka.apache.org/11/documentation/streams/developer-guide/testing.html你也可以使用
KafkaEmbedded，或者更好EmbeddedKafkaCluster. 例如，请查看kafka streams集成测试：https://github.com/apache/kafka/tree/trunk/streams/src/test/java/org/apache/kafka/streams/integration