@Configuration
public class KafkaProducerConfig
extends java.lang.Object
Constructor and Description |
---|
KafkaProducerConfig(java.lang.String bootstrapServers) |
Modifier and Type | Method and Description |
---|---|
org.springframework.kafka.core.KafkaTemplate<java.lang.Object,java.lang.Object> |
kafkaTemplate(org.springframework.kafka.core.ProducerFactory<java.lang.Object,java.lang.Object> producerFactory) |
org.springframework.kafka.core.ProducerFactory<java.lang.Object,java.lang.Object> |
producerFactory() |
public KafkaProducerConfig(@Value(value="${kafka.bootstrap-servers}") java.lang.String bootstrapServers)
@Bean public org.springframework.kafka.core.ProducerFactory<java.lang.Object,java.lang.Object> producerFactory()
@Bean public org.springframework.kafka.core.KafkaTemplate<java.lang.Object,java.lang.Object> kafkaTemplate(org.springframework.kafka.core.ProducerFactory<java.lang.Object,java.lang.Object> producerFactory)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.