如何使用JUnit5为Kafka消息使用者测试PACT

Question

在我们的项目中，我们使用JUnit5。我们希望通过pact测试我们的Kafka消息。在互联网上，我找到了一些JUnit 4示例以及一些有关JUnit 5和REST的示例。我到目前为止所拥有的是：

import au.com.dius.pact.consumer.MessagePactBuilder;
import au.com.dius.pact.consumer.MockServer;
import au.com.dius.pact.consumer.dsl.PactDslJsonBody;
import au.com.dius.pact.consumer.junit5.PactConsumerTestExt;
import au.com.dius.pact.consumer.junit5.PactTestFor;
import au.com.dius.pact.consumer.junit5.ProviderType;
import au.com.dius.pact.core.model.annotations.Pact;
import au.com.dius.pact.core.model.messaging.MessagePact;
import AdresseBean;
import PersonGeloeschtConsumer;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
import org.mockito.InjectMocks;
import org.mockito.Mock;
import org.mockito.junit.jupiter.MockitoExtension;

import java.util.UUID;

@ExtendWith(MockitoExtension.class)
@ExtendWith(PactConsumerTestExt.class)
@PactTestFor(providerName = "personservice-kafka")
public class PersonGeaendertEventConsumerPactTest {
    @InjectMocks
    private PersonGeloeschtConsumer personGeloeschtConsumer;

    @Mock
    private AdresseBean adresseBean;

    @Pact(provider = "personservice-kafka", consumer = "adresseservice-kafka")
    public MessagePact createPact(MessagePactBuilder builder) {
        PactDslJsonBody body = new PactDslJsonBody();
        body.stringType("eventUuid", UUID.randomUUID().toString())
            .stringMatcher("status", "NEU|GELOESCHT|GEAENDERT", "GELOESCHT")
            .integerType("id", 123l)
            .closeObject();
        return builder.given("Person wird geändert")
            .expectsToReceive("PersonGeaendertEvent")
            .withContent(body)
            .toPact();
    }

    @Test
    @PactTestFor(pactMethod = "createPact", providerType = ProviderType.ASYNCH)
    public void test(MockServer mockServer) throws Exception {
        // TODO
//        personGeloeschtConsumer.verarbeiteRecord(String message);
    }
}

在我的POM中，我具有以下依赖性：

<dependency>
    <groupId>au.com.dius</groupId>
    <artifactId>pact-jvm-consumer-junit5</artifactId>
    <version>4.0.1</version>
    <scope>test</scope>
</dependency>

我的问题是，如何将消息从createPact（）方法转换为测试方法。还有其他人使用JUnit 5和PACT来验证Kafka消息吗？

Answer 1

解决方案很简单：必须在以下位置传递MessagePact对象，而不是MockServer：

@Test
@PactTestFor(pactMethod = "createPact", providerType = ProviderType.ASYNCH)
public void test(MessagePact messagePact) throws Exception {
    String text = new String(messagePact.getMessages().get(0).contentsAsBytes());
    personGeloeschtConsumer.verarbeiteRecord(text);
}