Spring for Apache Kafka
Exception Handling in Spring Kafka & Kafka Streams | Deserialization, Processing & Production Errors
Join() methods in String for Apache Kafka Streams
The join() methods in Spring for Apache Kafka Streams are inner joins, used to join messages with the same key published to two Apache Kafka topics. For example, if you have two topics, customers and orders, to join messages with the same key in these… Read More
Apache Kafka Streams join() Explained | Window Joins & Grace Period
KTable in Spring for Apache Kafka Streams
In the previous tutorial, I introduced you to Spring for Apache Kafka and Apache Kafka Streams. I also showed you how to use the KStream class to consume and apply some operations to stream messages. Besides the KStream class, Spring for Apache Kafka Streams also… Read More
Introduction to Spring for Apache Kafka Stream
A stream in Apache Kafka is an unlimited sequence of messages continuously sent to an Apache Kafka topic. If you use the standard Spring for Apache Kafka library, you can easily subscribe and receive these messages. However, if you want to apply more operations to… Read More
Apache Kafka Streams KTable Explained | Stateful Stream Processing Made Simple
Apache Kafka Streams with Spring: Processing Events Using KStream
Send messages to Apache Kafka using the KafkaTemplate class of Spring for Apache Kafka
I have guided you on how to use the KafkaAdmin class of Spring for Apache Kafka to manage topics in Apache Kafka. To send or delete messages in Apache Kafka Topics in projects using Spring, you can use the KafkaTemplate class of this Spring for… Read More
Manage Apache Kafka using KafkaAdmin class of Spring for Apache Kafka
To manage Apache Kafka in projects using Spring, you can use the KafkaAdmin class in the Spring for Apache Kafka module of Spring. This KafkaAdmin class is a wrapper of the AdminClient class in the kafka-client library! Using the object of the KafkaAdmin class, you… Read More