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