Package org.springframework.kafka.jdocs.started.noboot

Class Config

java.lang.Object

org.springframework.kafka.jdocs.started.noboot.Config

@Configuration
@EnableKafka
public class Config
extends java.lang.Object

Code snippet for quick start.

Since:

2.7

Author:

Gary Russell

Constructor Summary

Constructors

Constructor	Description
Config()

Method Summary

Modifier and Type	Method	Description
ConsumerFactory<java.lang.Integer,java.lang.String>	consumerFactory()
KafkaTemplate<java.lang.Integer,java.lang.String>	kafkaTemplate(ProducerFactory<java.lang.Integer,java.lang.String> producerFactory)
Listener	listener()
ProducerFactory<java.lang.Integer,java.lang.String>	producerFactory()
Sender	sender(KafkaTemplate<java.lang.Integer,java.lang.String> template)

Methods inherited from class java.lang.Object

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

Constructor Detail

Config

public Config()

Method Detail

consumerFactory

@Bean
public ConsumerFactory<java.lang.Integer,java.lang.String> consumerFactory()

sender

@Bean
public Sender sender(KafkaTemplate<java.lang.Integer,java.lang.String> template)

listener

@Bean
public Listener listener()

producerFactory

@Bean
public ProducerFactory<java.lang.Integer,java.lang.String> producerFactory()

kafkaTemplate

@Bean
public KafkaTemplate<java.lang.Integer,java.lang.String> kafkaTemplate(ProducerFactory<java.lang.Integer,java.lang.String> producerFactory)