Package callofproject.dev.community.config.kafka

Class UserConsumerConfig

java.lang.Object

callofproject.dev.community.config.kafka.UserConsumerConfig

@EnableKafka
@Configuration
public class UserConsumerConfig
extends Object

Author:

Nuri Can ÖZTÜRK This class is a Spring Configuration class that provides configuration for Kafka consumer.

Constructor Summary

Constructors

Constructor	Description
UserConsumerConfig()

Method Summary

Modifier and Type	Method	Description
org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory<String,UserKafkaDTO>	configUserKafkaListener()	Constructs a new UserConsumerConfig.
org.springframework.kafka.core.ConsumerFactory<String,UserKafkaDTO>	userConfig()	Creates and configures the ConsumerFactory object for UserKafkaDTO.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

UserConsumerConfig

public UserConsumerConfig()

Method Details

configUserKafkaListener

@Bean
public org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory<String,UserKafkaDTO> configUserKafkaListener()

Constructs a new UserConsumerConfig.

userConfig

@Bean
public org.springframework.kafka.core.ConsumerFactory<String,UserKafkaDTO> userConfig()

Creates and configures the ConsumerFactory object for UserKafkaDTO.

Returns:

Configured ConsumerFactory object.