io.eventuate.tram.spring.consumer.kafka

Class EventuateTramKafkaMessageConsumerConfiguration

java.lang.Object

io.eventuate.tram.spring.consumer.kafka.EventuateTramKafkaMessageConsumerConfiguration

@Configuration
 @Import(value={TramConsumerCommonConfiguration.class,io.eventuate.messaging.kafka.spring.consumer.MessageConsumerKafkaConfiguration.class,io.eventuate.messaging.kafka.spring.consumer.KafkaConsumerFactoryConfiguration.class})
public class EventuateTramKafkaMessageConsumerConfiguration
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
EventuateTramKafkaMessageConsumerConfiguration()

Method Summary

Modifier and Type	Method and Description
MessageConsumerImplementation	messageConsumerImplementation(io.eventuate.messaging.kafka.consumer.MessageConsumerKafkaImpl messageConsumerKafka)

Methods inherited from class java.lang.Object

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

Constructor Detail

EventuateTramKafkaMessageConsumerConfiguration

public EventuateTramKafkaMessageConsumerConfiguration()

Method Detail

messageConsumerImplementation

@Bean
public MessageConsumerImplementation messageConsumerImplementation(io.eventuate.messaging.kafka.consumer.MessageConsumerKafkaImpl messageConsumerKafka)