Package callofproject.dev.community.config.kafka

Class KafkaProducer

java.lang.Object

callofproject.dev.community.config.kafka.KafkaProducer

@Service
public class KafkaProducer
extends Object

Author:

Nuri Can ÖZTÜRK Kafka Producer

Constructor Summary

Constructors

Constructor	Description
KafkaProducer(org.apache.kafka.clients.admin.NewTopic notificationTopic, org.springframework.kafka.core.KafkaTemplate<String,NotificationKafkaDTO> kafkaTemplate)	Constructor

Method Summary

Modifier and Type	Method	Description
void	sendNotification(NotificationKafkaDTO message)	Send notification

Methods inherited from class java.lang.Object

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

Constructor Details

KafkaProducer

public KafkaProducer(@Qualifier("notificationTopic")
 org.apache.kafka.clients.admin.NewTopic notificationTopic,
 org.springframework.kafka.core.KafkaTemplate<String,NotificationKafkaDTO> kafkaTemplate)

Constructor

Parameters:

notificationTopic - topic

kafkaTemplate - kafka template

Method Details

sendNotification

public void sendNotification(NotificationKafkaDTO message)

Send notification

Parameters:

message - message