Class KafkaConsumerConfig

java.lang.Object

org.chenile.pubsub.kafka.configuration.KafkaConsumerConfig

@EnableKafka
@Configuration
public class KafkaConsumerConfig
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private String	bootstrapAddress
private String	interceptorClass
private static final org.slf4j.Logger	logger
private PubSubEntryPoint	pubSubEntryPoint

Constructor Summary

Constructors

Constructor	Description
KafkaConsumerConfig()

Method Summary

Modifier and Type	Method	Description
org.springframework.kafka.core.ConsumerFactory<String,String>	consumerFactory()
org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory<String,String>	kafkaListenerContainerFactory()
void	listenGroupFoo2(String message, Map<String,Object> headers, String topic, String chenileTopic)
void	messageArrived(String topic, String messageContent, Map<String,Object> headers)

Methods inherited from class Object

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

Field Details

logger

private static final org.slf4j.Logger logger

bootstrapAddress

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

interceptorClass

@Value("${spring.kafka.consumer.interceptor:}")
private String interceptorClass

pubSubEntryPoint

@Autowired
private PubSubEntryPoint pubSubEntryPoint

Constructor Details

KafkaConsumerConfig

public KafkaConsumerConfig()

Method Details

consumerFactory

@Bean
public org.springframework.kafka.core.ConsumerFactory<String,String> consumerFactory()

kafkaListenerContainerFactory

@Bean
public org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory<String,String> kafkaListenerContainerFactory()

listenGroupFoo2

@KafkaListener(topics="chenile_global_service",
               groupId="foo1")
public void listenGroupFoo2(@Payload
 String message,
 @Headers
 Map<String,Object> headers,
 @Header("kafka_receivedTopic")
 String topic,
 @Header("chenile_topic")
 String chenileTopic)

messageArrived

public void messageArrived(String topic,
 String messageContent,
 Map<String,Object> headers)