kafka-test-api is a library Embedded Kafka with API to easy call in python.
By default kafka-test-api is build for Scala 2.12.13
git clone https://github.com/wpopielarski/kafka-test-api.git
cd kafka-test-api
sbt clean package
sbt packArchive
Product of build can be found in target/scala-2.12/kafka-test-api_2.12-1.0-SNAPSHOT.jar
To build product for Scala 2.11.12 and Spark 2.3.0 run
sbt ++2.11.12 clean package packArchive
Product of build can be found in target/scala-2.11/kafka-test-api_2.11-1.0-SNAPSHOT.jar
TODO