Como implementar o teste de contrato quando o kafka está envolvido na arquitetura de microsserviços?

Atualmente, estou trabalhando em um projeto em que temos a implementação kafka na arquitetura de micro serviços. Você conseguiu criar casos de teste de contrato para interação de tópicos mS a kafka usando pact-jvm?

Minha implementação é microservice1 publica uma mensagem para um cliente REST que, por sua vez, publica a mensagem no tópico Kafka. microservice2 usa o método GET para recuperar mensagens do tópico Kafka.

questionAnswers(1)

yourAnswerToTheQuestion