Package callofproject.dev.project.config.kafka

Class KafkaConsumer

java.lang.Object

callofproject.dev.project.config.kafka.KafkaConsumer

@Service
public class KafkaConsumer
extends Object

This class represents a Kafka consumer service responsible for listening to messages from a Kafka topic.

Constructor Summary

Constructors

Constructor	Description
KafkaConsumer(callofproject.dev.data.project.dal.ProjectServiceHelper serviceHelper, IUserMapper userMapper)	Constructs a new KafkaConsumer with the provided dependencies.

Method Summary

Modifier and Type	Method	Description
void	listenAuthenticationTopic(UserDTO dto)	Listens to the specified Kafka topic and processes UserDTO messages.

Methods inherited from class java.lang.Object

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

Constructor Details

KafkaConsumer

public KafkaConsumer(callofproject.dev.data.project.dal.ProjectServiceHelper serviceHelper,
 IUserMapper userMapper)

Constructs a new KafkaConsumer with the provided dependencies.

Parameters:

serviceHelper - The ProjectServiceHelper instance used for handling Kafka messages.

userMapper - The IUserMapper instance used for mapping UserDTO messages.

Method Details

listenAuthenticationTopic

@KafkaListener(topics="${spring.kafka.topic-name}",
               groupId="${spring.kafka.consumer.group-id}")
public void listenAuthenticationTopic(UserDTO dto)

Listens to the specified Kafka topic and processes UserDTO messages.

Parameters:

dto - The UserDTO message received from Kafka.