但是，如果拓扑使用KTable，则无法在Windows上关闭TopologyTestDriver。;import org.apache.kafka.streams.Topology; at org.apa
浏览 17提问于2019-07-19得票数 0
2回答
我正在尝试测试我的Kafka流应用程序。我构建了一个简单的拓扑结构，从输入主题中读取数据，并将相同的数据存储在状态存储中。 at org.apache.kafka.streams.TopologyTestDriver.<init>(TopologyTestDriver.java:403)
at org.apache.kaf
浏览 7提问于2020-09-22得票数 3
回答已采纳
我有卡夫卡流单元测试，基于一个非常伟大、可靠和方便的TopologyTestDriver：org.apache.kafka.streams.errors.TopologyException: Invalid topologyat org.apac
浏览 3提问于2020-05-03得票数 0
我在TopologyTestDriver上遇到了一个问题，因为设置属性是必须的:当拓扑试图将记录发布到主题中时，它会转到配置中提供的"url“。(StreamTask.java:304) at org.apache.kafka.streams
浏览 1提问于2018-10-17得票数 2
回答已采纳
我想用一个使用kafka- Streams - test -utils的单元测试来测试我的Kafka流拓扑。我使用这个库的时间已经很长了，并且我已经使用TestNG围绕我的测试构建了一些抽象层。(StreamTask.java:318)at org.apache.kafka.
浏览 0提问于2020-04-21得票数 1
回答已采纳
在我的测试application.yaml中，我放置了以下配置(我现在只测试第一个流，一旦工作成功，我想扩展它)：spring.cloud(TaskManager.java:1008) ~[kafka-streams-2.7.1.jar:na]
at org.apache.kafka.streams.processor.internals.StreamThread.pollPhase(StreamThread.java
浏览 4提问于2021-08-20得票数 0
回答已采纳
我试图使用kafka流来执行加窗口的聚合，并且只有在某个会话窗口关闭后才会发出结果。为了实现这一点，我使用了抑制函数。;import org.apache.kafka.streams.StreamsBuilder;import org.apache.kafka</e
浏览 0提问于2019-03-15得票数 1
回答已采纳
我正在写一个使用Kafka Streams，Spring-Kafka和Spring Boot的流应用程序。在使用Spring-Kafka时，我找不到任何信息来正确测试Kafka Streams DSL所做的流处理。
浏览 25提问于2019-08-31得票数 3
下面的简单代码说明了这一点：import org.apache.kafka.streams.{StreamsConfig, TopologyTestDriver}import org.apache.kafka.streams.scala.ks
浏览 3提问于2021-03-28得票数 1
在使用TopologyTestDriver时，我希望测试我的流，并对传入消息之间的中间状态进行分析。但是在使用TestOutputTopic.readKeyValuesToMap()之后，测试主题将被清除。如何在消息之间进行“窥视”和断言？;import org.apache.kafka.streams.kstream.Consumed;
import org.apache.kafka</e
浏览 19提问于2022-11-02得票数 0
回答已采纳
avroSerde.configure(avroSerdeConfig, false); // `false` for record values} at io.confluent.kafka.streams.
浏览 1提问于2018-10-10得票数 4
testDriver = new TopologyTestDriver(builder.build(), streamsConfiguration);
ConsumerRecordFactoryError:(70, 52) java: reference to create is ambiguous
both method create(K,V,long) in org.apache.kafka.streams.test.ConsumerRecordFactoryand met
浏览 1提问于2018-11-15得票数 1
回答已采纳
1回答
我使用一个spring引导启动器-父2.4.4作为我的spring启动依赖项，并使用kafka-streams 2.7.0。但是在我的应用程序类中正确地解决了..。;import org.apache.kafka.streams.StreamsBuilder;i
浏览 8提问于2021-04-13得票数 0
回答已采纳
2回答
在探索如何对卡夫卡流进行单元测试时，我遇到了ProcessorTopologyTestDriver，不幸的是，这个类似乎已经与版本0.10.1.0 ()分离了。谢谢拉蒙·加西亚
对于在Google搜索中到达这里的人，请注意测试驱动程序类现在是org.apache.kafka.stream
浏览 6提问于2017-04-05得票数 4
2回答
extends SpecificRecordBase implements SpecificRecord { public String name;我在卡夫卡流代码下面;import org.apache.kafka.streams.*;&g
浏览 2提问于2022-06-14得票数 0
回答已采纳
假设我想为下面的示例编写一个单元测试： https://github.com/confluentinc/kafka-streams-examples/blob/5.1.2-post/src/main/java/io/confluent/examples/streams/WikipediaFeedAvroLambdaExample.java 我尝试了以下方法，但这两种方法对我都无效： 1)使用To
浏览 12提问于2019-03-11得票数 2
javax.ws.rs-api" % "2.1" artifacts(Artifact("javax.ws.rs-api", "jar", "jar"))
libraryDependencies += "org.apache.kafka" % &q
浏览 0提问于2018-12-12得票数 2
我使用TopologyTestDriver运行了一个简单的测试，并引发了以下异常：
原因: org.apache.kafka.common.serialization.StringSerializer.serialize:66) at org.apache.kafka.streams.state.internals.MeteredKeyValueBytesStore$1无法将com.example.kafka.streams.topology.Test:89)在org
浏览 2提问于2018-12-27得票数 1
回答已采纳
我们正在构建一个将使用Kafka Streams的应用程序。我们正在寻找示例示例，它向我们展示了如何为场景编写测试用例，其中我们从Kafka拓扑调用外部服务。基本上，需要以某种方式模拟外部调用，因为服务可能并不总是在运行。我们使用TopologyTestDriver编写测试用例。由于这个外部调用，我们的测试用例没有执行。topologyTestDriver;
@A
浏览 0提问于2021-06-03得票数 2
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号