使用TopologyTestDriver时指定输出主题的分区数

Question

我在为 Kafka Streams 应用程序编写测试时使用

TopologyTestDriver

。有没有办法配置

InputTestTopic

和

OutputTestTopic

的分区数量？

在我们的一些应用中，记录处理逻辑相当复杂，当输入主题包含多个分区时，记录处理逻辑会变得更加复杂。因此，使用包含多个分区的输入主题彻底测试记录处理逻辑将非常有用。

Answer 1

TestTopologyDriver 似乎模拟单分区主题，因此我们可能无法配置多个分区

这是java的摘录 https://kafka.apache.org/24/javadoc/org/apache/kafka/streams/TopologyTestDriver.html

处理消息您的测试可以在任何一个上提供新的输入记录 拓扑源消耗的主题。这位试驾司机 模拟单分区输入主题。这是一个例子 在名为 input-topic 的主题上输入消息：

ConsumerRecordFactory 工厂 = 新 ConsumerRecordFactory(strSerializer, strSerializer); driver.pipeInput(factory.create("input-topic","key1", "value1"));