Spring Boot Kafka Microservices - #12 - Configure Kafka Consumer in StockService Microservice

❮ Previous Lecture Next Lecture ❯

---

Welcome to Spring Boot Kafka Event-Driven Microservices Series. In this lecture, we will Configure Kafka Consumer in StockService Microservice.

Lecture - #12 - Configure Kafka Consumer in StockService Microservice

Source Code used in Lecture for Your Reference

Configure Kafka Consumer in StockService Microservice

Open the application.properties file of the stock-service project and configure Kafka consumer.

server.port=8081
spring.kafka.consumer.bootstrap-servers: localhost:9092
spring.kafka.consumer.group-id: stock
spring.kafka.consumer.auto-offset-reset: earliest
spring.kafka.consumer.key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consumer.value-deserializer: org.springframework.kafka.support.serializer.JsonDeserializer
spring.kafka.consumer.properties.spring.json.trusted.packages=*
spring.kafka.topic.name=order_topics

We are using the following Consumer property to convert JSON into Java object:

spring.kafka.consumer.value-deserializer: org.springframework.kafka.support.serializer.JsonDeserializer

Let's understand the meaning of the above properties.

spring.kafka.consumer.bootstrap-servers - Comma-delimited list of host:port pairs to use for establishing the initial connections to the Kafka cluster. Overrides the global property, for consumers.

spring.kafka.consumer.group-id - A unique string that identifies the consumer group to which this consumer belongs.

spring.kafka.consumer.auto-offset-reset - What to do when there is no initial offset in Kafka or if the current offset no longer exists on the server.

spring.kafka.consumer.key-deserializer - Deserializer class for keys.

spring.kafka.consumer.value-deserializer - Deserializer class for values.

❮ Previous Lecture Next Lecture ❯

---