Example Java Kafka Consumer
Source Code
https://github.com/pactflow/example-consumer-java-kafka
: https://testdemo.pactflow.io/pacticipants/pactflow-example-bi-directional-provider-readyapi/branches/master/latest-version/can-i-deploy/to-environment/production/badge (master/master pact)
This is an example of a Java kafka consumer that uses Pact, API Hub for Contract Testing and GitHub Actions to ensure that it is compatible with the expectations its consumers have of it.
The project uses a Makefile to simulate a very simple build pipeline with two stages - test and deploy.
See the canonical consumer example here: https://github.com/pactflow/example-consumer See also the full API Hub for Contract Testing CI/CD Workshop for which this can be substituted in as the "consumer".
In the following diagram, we'll be testing the "Product API", a simple HTTP service that exposes product information as a REST API, which is fed events from an Event API on the product topic.
Pre-requisites
Software:
Usage
Running the API and kafka listener locally:
make startProducing test events into the
producttopic:make test-eventsRetrieve latest products:
curl localhost:8080/products