Class KafkaProducerConfig

java.lang.Object
org.chenile.pubsub.kafka.configuration.KafkaProducerConfig
@Configuration public class KafkaProducerConfig extends Object

  • Field Details

    • bootstrapAddress

      @Value("${spring.kafka.bootstrap-server}") private String bootstrapAddress

  • Constructor Details

    • KafkaProducerConfig

      public KafkaProducerConfig()

  • Method Details

    • createAdminClient

      @Bean public org.apache.kafka.clients.admin.AdminClient createAdminClient()

    • producerFactory

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

    • kafkaTemplate

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