Skip to content
Test examples of kafka-clients: unit, integration, end-to-end
Branch: master
Clone or download
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Permalink
Type Name Latest commit message Commit time
Failed to load latest commit information.
.mvn/wrapper
consumer-producer-clients
data-pipeline
e2e
embedded-cluster
streams-client
.gitignore
.travis.yml
docker-compose.yml
mvnw
mvnw.cmd
pom.xml
readme.md

readme.md

Build Status

Kafka-clients: writing automated tests

Run all tests:

./mvnw clean install -DskipIntegrationTests=false

Modules and approaches

  1. streams-client module contains examples of unit-tests for kafka-streams topologies with kafka-streams-test-utils. Approach covers testing topologies (stateful & stateless processors) with different serdes including avro and confluent schema registry.
  2. embedded-kafka-cluster module is example of kafka-embedded cluster in memory (1 Zookeeper, 1 Kafka broker, 1 Confluent schema registry). Embedded kafka cluster is used for integration test of kafka-client application.
  3. consumer-producer-clients module contains examples of integration tests with embedded kafka cluster and kafka based applications with Producer/Consumer API
  4. data-pipeline module contains examples of integration tests with embedded kafka cluster, wire-mock and kafka based applications with Streams API
  5. e2e module contains IT test for data pipeline, using testcontainers

TODO:

  • Makefile
  • update vers java 8 -> 12 !NB: Reflection use -> only java8 currently
  • update vers junit 4 -> 5

Important notes

References

You can’t perform that action at this time.