/blog-kafka-streams

Sources for blog post using kafka-streams

Primary LanguageJava

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.