org.springframework.integration.x.kafka

Class KafkaMessageTransformer

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

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware, org.springframework.integration.support.context.NamedComponent, org.springframework.integration.transformer.GenericTransformer<org.springframework.messaging.Message<?>,org.springframework.messaging.Message<?>>, org.springframework.integration.transformer.Transformer

public class KafkaMessageTransformer
extends 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>>

A transformer that transforms the Kafka messages into Map of partition and payload. Since kafka source module has a single topic, the topic information can be removed.

Author:

Ilayaperumal Gopinathan

Field Summary

Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport

logger

Constructor Summary

Constructors

Constructor and Description
KafkaMessageTransformer()

Method Summary

Methods

Modifier and Type	Method and Description
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) Transform message payload to Map where partitionIndex is the key and message payload is the value.

Methods inherited from class org.springframework.integration.transformer.AbstractPayloadTransformer

doTransform

Methods inherited from class org.springframework.integration.transformer.AbstractTransformer

transform

Methods inherited from class 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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

KafkaMessageTransformer

public KafkaMessageTransformer()

Method Detail

transformPayload

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)
                                                                      throws java.lang.Exception

Transform message payload to Map where partitionIndex is the key and message payload is the value.

Specified by:

transformPayload in class 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>>

Throws:

java.lang.Exception