consumer-producer-clients

Description

Module contains examples of testing Kafka Producer/Consumer APIs with Kafka cluster in memory. Testing kafka-client application(s) in isolation.

NB!: Some of client properties have specific requirements about how cluster should be setup. Example: processing.guarantee:exactly_once

TODO

Module contains examples of testing Kafka Consumer/Producer APIs with:

• embedded kafka + producer/consumer
• embedded kafka + producer/consumer + avro
• cleanup test

Related Issues

• issue-#26

Additional Info

• scalatest-embedded-kafka
• kafka-it-embedded
• embedded-single-node-kafka-cluster