Serde and Kafka Streams In order to push / pull messages from Kafka we need to use Serde. I have found that if you create a Serializer / Deserialzer like following then it becomes really useful to create the Serde for your types. You can also use the method to create a GenericSerde to serialize… Continue reading »
Kafka Streams Config’s General Properties In this post, I just need to add Kafka Stream configuration which I have to use over and over again for a Kafka streams application. This can be used when developing a new Kafka Streams application. First we need to introduce configurations for Stream. They include details of broker and… Continue reading »
Kafka Tools – kafka.tools.ReplayLogProducer Replay Log Producer is a Kafka tool available to copy messages from one Kafka Topic to the other in the same Broker cluster. This supports copying a limited or all messages from a Kafka Topic. The tool is specially useful in a development environment when we want to test something with… Continue reading »
Kafka Streams – Interactive Queries (Intra Application Instance) Kafka Streams application need to maintain KTables in an internal application store. It maintains the store using RocksDB. It even allows to query this store during application lifecycle anywhere from the application parts. Let’s first create a simple application KafkaStreamsInteractiveQueriesApp. It is a simple Scala Application. In… Continue reading »
Purging Data in a Kafka Topics If you have been working with Kafka for sometime, you might need to purge data in a particular topic. In a dev environment, you might worked it around by just publishing and consuming from a different topic. But there are some cases when you might want to purge data… Continue reading »
Kafka Streams: Converting KStream to KTable There are no methods in KStream to convert into a KTable. But there are workarounds to do that. They are as follows: Write on a Kafka Topic and read back as Kable We can also write to an intermediate Kafka Topic and read it back using StreamBuilder. Here is… Continue reading »
Kafka Streams – Merging multiple KStream (s) In this post we are going to see how we can merge messages from multiple topics into a single topic in using Kafka Streams. In the example scenario, we will be using heart beat data for four sensors and merge into a single topic as follows: Here we… Continue reading »
Confluent – Using off-the-shelf-connectors with Landoop’s Kafka Connect UI In this post we are going to see how easy it is to run a Kafka Connector in order to source data in Kafka using a well designed tool like Landoop’s Kafka Connect UI. We can use Kafka Connect’s REST API to determine what connectors are… Continue reading »
Setting up Landoop’s Kafka-Connect-ui on Mac In this post, we are going to setup the third of the series of tools by Landoop to manage Confluent services for Kafka. Landoop provides Kafka-connect-ui to manage connectors in Kafka-connect. The tools is available as a Docker image on DockerHub, so let’s first pull it on our machine…. Continue reading »
Using Landoop’s Schema Registry UI In this post, we are going to setup Schema Registry UI for Confluent’s schema registry using Docker Image for the tool. Schema Registry is an amazing tool by Landoop. It’s available in Github. Let’s first pull the image from Docker Hub. Now we can simply run the docker image by… Continue reading »