Class KafkaConfiguration

java.lang.Object

org.chenile.pubsub.kafka.configuration.KafkaConfiguration

@Configuration
public class KafkaConfiguration
extends Object

Kafka-related Spring configuration for Chenile.

Constructor Summary

Constructors

Constructor	Description
KafkaConfiguration()

Method Summary

Modifier and Type	Method	Description
ChenilePub	chenilePub(org.springframework.kafka.core.KafkaTemplate<String,String> kafkaTemplate, PubSubInfoProvider pubSubInfoProvider)
WildCardsTopic	wildCardsTopic()

Methods inherited from class Object

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

Constructor Details

KafkaConfiguration

public KafkaConfiguration()

Method Details

chenilePub

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

wildCardsTopic

@Bean
public WildCardsTopic wildCardsTopic()