Kafka Consumer

In this tutorial, you will learn about the retryable and non-retryable exceptions in Apache Kafka. You’ll learn how to create your own custom exceptions and how to register then with Kafka’s DefaultErrorHandler object. To demonstrate how retryable and not retryable exceptions work, I will use the Kafka Consumer Spring Boot Microservice, which I created earlier.…

Read More Retryable and Not Retryable Exceptions in Apache Kafka

In this tutorial, you will learn how recover from deserialization errors gracefully in your Kafka Consumer Spring Boot Microservice. You’ll see how to use specific settings to ensure that a single problematic message doesn’t disrupt your message processing. By the end, your consumer will be able to skip over errors and continue processing subsequent messages…

Read More Kafka Consumer: Handle Deserialization Errors

In this tutorial, I will guide you through the process of setting up a Kafka Consumer using the @Configuration class and the @Bean method. This approach offers more flexibility and control compared to using the application.properties file. Kafka consumer configuration can be achieved in two primary ways in a Spring Boot application: Using the application.properties…

Read More Kafka Consumer Configuration in the @Bean Method

In this tutorial, I will guide you through setting up a Kafka Consumer in a Spring Boot application. You will learn how to configure the consumer properties, create a listener class using the @KafkaListener annotation, and how to process messages with the @KafkaHandler annotation. Let’s start with the configuration. Kafka Consumer Configuration in application.properties In…

Read More Creating Kafka Consumer in Spring Boot Microservice

In this lesson, you will learn how to consume messages or how to read messages from Apache Kafka topic using Kafka Consumer Command Line Interface(CLI). To learn how to produce or send messages to Kafka topic, please read the following tutorial: Kafka Producer CLI – Produce/Send message to Kafka topic. Consuming Messages From the Beginning…

Read More Kafka Consumer CLI – Consume/Read from Kafka Topic