クラス KafkaJacksonConfiguration
java.lang.ObjectSE
org.springframework.modulith.events.kafka.KafkaJacksonConfiguration
@AutoConfiguration
@AutoConfigureBefore(org.springframework.boot.autoconfigure.kafka.KafkaAutoConfiguration.class)
@ConditionalOnClass(com.fasterxml.jackson.databind.ObjectMapper.class)
@ConditionalOnProperty(name="spring.modulith.events.kafka.enable-json",
havingValue="true",
matchIfMissing=true)
@PropertySource("classpath:kafka-json.properties")
class KafkaJacksonConfiguration
extends ObjectSE
デフォルトで JSON をトランスポート形式として使用するように Spring for Apache Kafka を自動構成します。
- 導入:
- 1.1
- 作成者:
- Oliver Drotbohm
コンストラクター概要
コンストラクター方法の概要
修飾子と型メソッド説明(package private) org.springframework.kafka.support.converter.ByteArrayJsonMessageConverterjsonMessageConverter(ObjectProvider<com.fasterxml.jackson.databind.ObjectMapper> mapper)
コンストラクターの詳細
KafkaJacksonConfiguration
KafkaJacksonConfiguration()
方法の詳細
jsonMessageConverter
@Bean @ConditionalOnMissingBean(org.springframework.kafka.support.converter.RecordMessageConverter.class) org.springframework.kafka.support.converter.ByteArrayJsonMessageConverter jsonMessageConverter(ObjectProvider<com.fasterxml.jackson.databind.ObjectMapper> mapper)