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 é ...