static <K,V> KafkaPublisherConfiguration.Builder<K,V> |
KafkaPublisherConfiguration.builder() |
KafkaPublisherConfiguration.Builder<K,V> |
KafkaPublisherConfiguration.Builder.withMessageConverter(KafkaMessageConverter<K,V> messageConverter)
|
KafkaPublisherConfiguration.Builder<K,V> |
KafkaPublisherConfiguration.Builder.withMessageMonitor(MessageMonitor<? super EventMessage<?>> messageMonitor)
|
KafkaPublisherConfiguration.Builder<K,V> |
KafkaPublisherConfiguration.Builder.withMessageSource(SubscribableMessageSource<EventMessage<?>> messageSource)
|
KafkaPublisherConfiguration.Builder<K,V> |
KafkaPublisherConfiguration.Builder.withProducerFactory(ProducerFactory<K,V> producerFactory)
|
KafkaPublisherConfiguration.Builder<K,V> |
KafkaPublisherConfiguration.Builder.withPublisherAckTimeout(long timeoutInMillis) |
KafkaPublisherConfiguration.Builder<K,V> |
KafkaPublisherConfiguration.Builder.withTopic(String topic)
Configure Kafka topic for publishing messages, default to Axon.EventBus .
|