文件名称：kafka-testing:kafka-clients的测试示例
文件大小：155KB
文件格式：ZIP
更新时间：2024-06-15 13:22:34
kafka-streams embedded-kafka kafka-testing kafka-streams-test-utils embeddedsinglenodekafkacluster
Kafka客户端：编写自动化测试 运行所有测试： ./mvnw clean install -DskipIntegrationTests=false 模块和方法 包含使用kafka-streams拓扑的单元测试示例。 方法涵盖了使用不同的serdes包括和）测试拓扑（有状态和无状态处理器）的方法。 是内存中的示例（1个Zookeeper，1个Kafka代理，1个Confluent模式注册表）。 嵌入式kafka集群用于kafka-client应用程序的集成测试。 包含与以及具有基于kafka的应用程序进行集成测试的示例 包含使用与， wire-mock和基于kafka的应用程序进行集成测试的示例 e2e模块包含使用测试容器的数据管道的IT测试 去做： 生成文件 更新vers Java 8 -> 12 !NB ：反射使用->当前仅java8 更新vers junit 4 ->
【文件预览】：
kafka-testing-master
----.travis.yml(177B)
----pom.xml(6KB)
----data-pipeline()
--------http-producer()
--------pom.xml(893B)
--------readme.md(331B)
--------schema()
--------data_pipeline.png(21KB)
--------http-materializer()
--------database.json(132B)
--------docker-compose.yml(2KB)
----embedded-cluster()
--------pom.xml(2KB)
--------readme.md(861B)
--------src()
----readme.md(2KB)
----mvnw(10KB)
----streams-client()
--------pom.xml(2KB)
--------readme.md(578B)
--------src()
----e2e()
--------pom.xml(2KB)
--------readme.md(2KB)
--------src()
--------docker-compose.test.yml(3KB)
----docker-compose.yml(1017B)
----.gitignore(46B)
----consumer-producer-clients()
--------pom.xml(2KB)
--------readme.md(1KB)
--------src()
----.mvn()
--------wrapper()
----mvnw.cmd(6KB)