integration-testing - 在嵌入式 kafka 的集成测试中启动 Kafka Streams 应用程序

Question

我正在尝试使用嵌入式 kafka 进行 kafka 流应用程序的集成测试。我能够在嵌入式 kafka 中设置主题并向该主题生成消息。但是当我使用以下 KafkaStreams kafkaStreams = this.streamsBuilderFactoryBean.getKafkaStreams(); 启动我的 kafka 流时 StreamsBuilder 流构建器 = 新 StreamsBuilder(); KStream 流 = streamsBuilder.stream(INPUT_TOPIC);

流状态处于“重新平衡”状态。请确认以上是否是启动流应用程序的正确方法。谢谢