Modifier and Type | Method and Description |
---|---|
KafkaMessageConverter<String,byte[]> |
KafkaAutoConfiguration.kafkaMessageConverter(Serializer eventSerializer) |
Modifier and Type | Method and Description |
---|---|
Fetcher |
KafkaAutoConfiguration.kafkaFetcher(ConsumerFactory<String,byte[]> consumerFactory,
KafkaMessageConverter<String,byte[]> messageConverter) |
KafkaPublisher<String,byte[]> |
KafkaAutoConfiguration.kafkaPublisher(ProducerFactory<String,byte[]> producerFactory,
EventBus eventBus,
KafkaMessageConverter<String,byte[]> messageConverter,
AxonConfiguration configuration) |
Modifier and Type | Class and Description |
---|---|
class |
DefaultKafkaMessageConverter
Converts:
EventMessage to kafkaMessage and message read from
Kafka back
to EventMessage (if possible). |
Modifier and Type | Method and Description |
---|---|
AsyncFetcher.Builder<K,V> |
AsyncFetcher.Builder.withMessageConverter(KafkaMessageConverter<K,V> converter)
Configure the converter which converts Kafka messages to Axon messages.
|
Modifier and Type | Method and Description |
---|---|
KafkaMessageConverter<K,V> |
KafkaPublisherConfiguration.getMessageConverter() |
Modifier and Type | Method and Description |
---|---|
KafkaPublisherConfiguration.Builder<K,V> |
KafkaPublisherConfiguration.Builder.withMessageConverter(KafkaMessageConverter<K,V> messageConverter)
Configure
KafkaMessageConverter . |
Copyright © 2010–2018. All rights reserved.