我正在使用多个使用Kafka进行异步通信的应用程序。这些应用程序由多个部门管理,合同测试适用于确保通信期间使用的消息遵循预期的模式,并将根据合同规范进行演变。
听起来python的pact库非常合适,因为它有助于为HTTP和消息集成创建契约测试。
我想要做的是发送一个HTTP请求,然后立即收听适当的、专门的Kafka主题。但是似乎测试迫使我指定HTTP代码,即使我期望的是没有HTTP状态代码的队列中的消息。此外,HTTP请求似乎是在使用者监听之前发送的。下面是一些示例代码。
from pact.consumer import Consumer as p_Consumer
from pact.p
pact consumer是否测试生成合同json文件?
我正在学习pact,并被问及消费者测试的目的是什么?它测试测试类定义的响应。
在我下面的代码中。我用200和简单的主体定义了一个响应,然后通过mockProvider调用来测试它。看起来没用。有谁能给我一些导游。
public class PactTest {
@Rule
public PactProviderRuleMk2 mockProvider
= new PactProviderRuleMk2("test-provider", "localhost", 8017, thi
我正试着在JUnit5上运行一个协议测试。我们对其他人使用JUnit4,但这个将是JUnit5。使用JUnit5方法上的pact注释运行RequestResponsePact测试时会发生错误。
错误:No method annotated with @Pact was found on test class ConsumerContractTest for provider ''。
我见过,但这是由于@PactTestFor(pactMethod = "examplePact")与@Pact方法名称不匹配造成的。但在我的代码中它是匹配的。
我似乎无法理解为什么我
我正在尝试使用mvn clean test运行Pact Provider测试(用Java开发)。它在成功执行Pact测试后抛出错误:
[TestNG] Reporter org.testng.reporters.SuiteHTMLReporter@40298285 failed java.lang.NullPointerException
at java.lang.String.compareTo(String.java:1155)
at org.testng.reporters.SuiteHTMLReporter$1.compare(SuiteHTMLReporter.java:320)
P
我是Apache Kafka的新手。作为一个小项目的一部分,我试图将一个文本日志文件作为一条消息放入Kafka中。我遇到了一些编码错误。Kafka的java API (据我所知)包含主要用于字符串编码的条款。
作为一种变通方法,我在Kafka中逐行放置了日志文件,其中每一行代表一条消息,但这并不能解决我最初的问题陈述--一个文件就是一条消息。