This is the accompanying source for the Blog post.
Kafka can be run as a docker image as presented kafka-docker. We can play around with topics with different partitions by changing the docker-compose.yml
environment: KAFKA_CREATE_TOPICS: "logs:1:3,Topic2:1:1:compact"
Events can be written into Kafka with log-events-generator.
StartSimpleConsumers showcase the standard Kafka Consumer.
StartLowLevelProcessor is used to showcase a simple scenario using the low-level Processor API.