Package callofproject.dev.service.notification.config.kafka

Class KafkaConsumer

java.lang.Object

callofproject.dev.service.notification.config.kafka.KafkaConsumer

@Component
public class KafkaConsumer
extends Object

Kafka consumer.

Constructor Summary

Constructors

Constructor	Description
KafkaConsumer(NotificationService notificationService, org.springframework.messaging.simp.SimpMessagingTemplate messagingTemplate)	Constructor.

Method Summary

Modifier and Type	Method	Description
void	projectServiceListener(NotificationUserResponseDTO message)	Listen to the Kafka topic.

Methods inherited from class java.lang.Object

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

Constructor Details

KafkaConsumer

public KafkaConsumer(NotificationService notificationService,
 org.springframework.messaging.simp.SimpMessagingTemplate messagingTemplate)

Constructor.

Parameters:

notificationService - The notification service.

messagingTemplate - The messaging template.

Method Details

projectServiceListener

@KafkaListener(topics="${spring.kafka.consumer.topic-name}",
               groupId="${spring.kafka.consumer.group-id}")
public void projectServiceListener(NotificationUserResponseDTO message)

Listen to the Kafka topic.

Parameters:

message - The message.