KafkaTopConfig

java.lang.Object

api.mpba.rastvdmy.config.KafkaTopConfig

@Configuration public class KafkaTopConfig extends Object

This class is responsible for the configuration of Kafka topics. It provides a bean for creating a new Kafka topic named "messages".

Constructor Summary

Constructors

Constructor

Description

KafkaTopConfig()
Method Summary

Modifier and Type

Method

Description

org.apache.kafka.clients.admin.NewTopic

createTopic()

This method provides a NewTopic bean.

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

Constructor Details
- KafkaTopConfig
  
  public KafkaTopConfig()
Method Details
- createTopic
  
  @Bean public org.apache.kafka.clients.admin.NewTopic createTopic()
  
  This method provides a NewTopic bean. The NewTopic represents a new topic to be created in Kafka. The name of the topic is "messages".
  
  Returns:
  
  A NewTopic instance representing a topic named "messages".