Package com.ecom.winners.configurations

Class KafkaConfiguration

java.lang.Object

com.ecom.winners.configurations.KafkaConfiguration

@Configuration
public class KafkaConfiguration
                    extends Object

Constructor Summary

Constructors

Constructor	Description
KafkaConfiguration()

Method Summary

Modifier and Type	Method	Description
org.apache.kafka.clients.admin.NewTopic	topic (String weeklyWinnerTopic, int partitions, int replications)

Methods inherited from class java.lang.Object

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

Constructor Details

KafkaConfiguration

public KafkaConfiguration()
                                        

Method Details

topic

@Bean(name="topic")
public org.apache.kafka.clients.admin.NewTopic topic
                                            
                                            (@Value("${spring.kafka.template.default-topic}")
 String weeklyWinnerTopic,
 @Value("${spring.kafka.winner.topic.partitions}")
 int partitions,
 @Value("${spring.kafka.winner.topic.replications}")
 int replications)