Intro to Kafka - Consumer groups

June 20, 2021
kafkakotlin

Consumers can form groups, aptly named “consumer groups”. These consumer groups determine what records a consumer receives. I know that…

Intro to Kafka - Consumers

May 09, 2021
kafkakotlin

Consumers make up the Kafka client code that reads records from topics, working at the opposite end of the chain as producers and benefiting…

Intro to Kafka - Producers

April 24, 2021
kafkakotlin

Producers make up the Kafka client code that sends records to topics. These clients dramatically reduce the complexity of leveraging Kafka…

Intro to Kafka - Topics and partitions

April 12, 2021
kafka

Topics Kafka, at a high level, stores records in topics. When handing a new record off to Kafka, you must decide the name of the topic you…

Kafka producer and consumer written with Kotlin

April 03, 2021
kafkakotlin

I wanted to write a short and sweet blog post on writing a Kafka producer and consumer in Kotlin before delving deeper into the topic of…

Running Kafka locally with Docker

March 28, 2021
kafkadocker

There are two popular Docker images for Kafka that I have come across: Bitmami/kafka (Github) wurstmeister/kafka (Github) I chose these…

Public val with a private backing field

March 14, 2021
kotlin

As learnt through many years of writing Java code, we have come to the collective decision to use getters and setters instead of directly…

All experience matters

March 12, 2021
general

I wanted to write down my thoughts about “experience” as it is something that I have been thinking about over the last couple of months…

Backwards compatibility of Kotlin's default arguments

March 07, 2021
kotlin

Kotlin’s default arguments can make APIs easier to understand as a user and more effortless to write as a developer. No more manually…

Sending a HTTP request in Apache Flink

February 07, 2021
javaapache flinkflink

You can send a HTTP request in an Apache Flink application using code similar to the following: The HTTP client you use doesn’t have to be…

All posts