Package com.arms.config

Class KafkaConfig

java.lang.Object

com.arms.config.KafkaConfig

@Configuration
@RefreshScope
public class KafkaConfig
extends Object

Constructor Summary

Constructors

Constructor	Description
KafkaConfig()

Method Summary

Modifier and Type	Method	Description
org.springframework.kafka.core.KafkaAdmin	kafkaAdmin()
org.apache.kafka.clients.admin.AdminClient	kafkaAdminClient(org.springframework.kafka.core.KafkaAdmin kafkaAdmin)
org.springframework.kafka.core.KafkaTemplate<String,String>	kafkaTemplate(org.springframework.kafka.core.ProducerFactory<String,String> producerFactory)
org.springframework.kafka.core.ProducerFactory<String,String>	producerFactory()
org.apache.kafka.clients.admin.NewTopic	reqAddTopic()	REQADD 토픽 생성 (싱글 파티션은 순서보장으로 인한 설정) Partitions: 1 Replication Factor: 3 Retention: 4 week CleanUp: delete

Methods inherited from class java.lang.Object

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

Constructor Details

KafkaConfig

public KafkaConfig()

Method Details

kafkaAdmin

@Bean
public org.springframework.kafka.core.KafkaAdmin kafkaAdmin()

kafkaAdminClient

@Bean
public org.apache.kafka.clients.admin.AdminClient kafkaAdminClient(org.springframework.kafka.core.KafkaAdmin kafkaAdmin)

reqAddTopic

@Bean
public org.apache.kafka.clients.admin.NewTopic reqAddTopic()

REQADD 토픽 생성 (싱글 파티션은 순서보장으로 인한 설정) Partitions: 1 Replication Factor: 3 Retention: 4 week CleanUp: delete

kafkaTemplate

@Bean
public org.springframework.kafka.core.KafkaTemplate<String,String> kafkaTemplate(org.springframework.kafka.core.ProducerFactory<String,String> producerFactory)

producerFactory

@Bean
public org.springframework.kafka.core.ProducerFactory<String,String> producerFactory()