| 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.