KafkaTopicProvider

java.lang.Object

callofproject.dev.community.config.kafka.KafkaTopicProvider

@Component public class KafkaTopicProvider extends Object

Author:: Nuri Can ÖZTÜRK This class is a Spring Component class that provides Kafka topics.

Constructor Summary

Constructors

Constructor

Description

KafkaTopicProvider()

Constructs a new KafkaTopicProvider.
Method Summary

Modifier and Type

Method

Description

org.apache.kafka.clients.admin.NewTopic

provideNotificationTopic()

Create a new Kafka topic.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- KafkaTopicProvider
  
  public KafkaTopicProvider()
  
  Constructs a new KafkaTopicProvider.
Method Details
- provideNotificationTopic
  
  @Bean("notificationTopic") public org.apache.kafka.clients.admin.NewTopic provideNotificationTopic()
  
  Create a new Kafka topic.
  
  Returns:
  
  The newly created Kafka notification topic.