An example of running kafka (scalable to many kafkas) with zookeeper using docker, using enforced ssl and sasl.
do run ./createssl.sh to create new ssl certificates. note that the consumer and the server use the same keystore since it's been signed by a custom CA.
- docker-compose up
- check the file
src/test/kotlin/kafka/kafkaTests.kt
- you can run it from intelliJ (make sure the broker is running)
note the tests have the bootstrap servers as localhost but the docker container name is kafka01, they are connected via the port being exposed to the host. if creating a container using a jar file, make sure to use the container name.