KafkaMessageTransformer (Spring XD 1.3.2.RELEASE API)

java.lang.Object
- org.springframework.integration.context.IntegrationObjectSupport
- - org.springframework.integration.transformer.AbstractTransformer
  - - org.springframework.integration.transformer.AbstractPayloadTransformer<java.util.Map<java.lang.String,java.util.Map<java.lang.Integer,java.util.List<java.lang.Object>>>,java.util.Map<java.lang.Integer,java.lang.Object>>
    - - org.springframework.integration.x.kafka.KafkaMessageTransformer

フィールドのサマリー
- クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたフィールド
  logger

コンストラクター
コンストラクターと説明
`KafkaMessageTransformer()`

メソッド
修飾子と型	メソッドと説明
`protected java.util.Map<java.lang.Integer,java.lang.Object>`	`transformPayload(java.util.Map<java.lang.String,java.util.Map<java.lang.Integer,java.util.List<java.lang.Object>>> payload)` メッセージペイロードを Map に変換します。ここで、partitionIndex はキーで、メッセージペイロードは値です。

クラス org.springframework.integration.transformer.AbstractPayloadTransformer から継承されたメソッド
doTransform

クラス org.springframework.integration.transformer.AbstractTransformer から継承されたメソッド
transform

クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたメソッド
afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getComponentType, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, onInit, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setTaskScheduler, toString

クラス java.lang.Object から継承されたメソッド
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

クラス KafkaMessageTransformer