クラス KafkaJackson2Configuration

java.lang.ObjectSE
org.springframework.modulith.events.kafka.KafkaJackson2Configuration

@AutoConfiguration @AutoConfigureBefore(org.springframework.boot.kafka.autoconfigure.KafkaAutoConfiguration.class) @AutoConfigureAfter(KafkaJacksonConfiguration.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 KafkaJackson2Configuration extends ObjectSE
Jackson 2 経由で、デフォルトで JSON をトランスポート形式として使用するように Spring for Apache Kafka を自動構成します。
導入:
2.0
作成者:
Oliver Drotbohm
  • コンストラクターの詳細

    • KafkaJackson2Configuration

      KafkaJackson2Configuration()
  • 方法の詳細

    • jackson2jsonMessageConverter

      @Bean @ConditionalOnMissingBean(org.springframework.kafka.support.converter.RecordMessageConverter.class) @ConditionalOnClass(com.fasterxml.jackson.databind.ObjectMapper.class) org.springframework.kafka.support.converter.ByteArrayJsonMessageConverter jackson2jsonMessageConverter(ObjectProvider<com.fasterxml.jackson.databind.ObjectMapper> mapper)