Package org.springframework.integration.kafka.dsl

Class KafkaShareMessageDrivenChannelAdapterSpec<K,V,S extends KafkaShareMessageDrivenChannelAdapterSpec<K,V,S>>

java.lang.Object

org.springframework.integration.dsl.IntegrationComponentSpec<S,P>

org.springframework.integration.dsl.MessageProducerSpec<S,KafkaShareMessageDrivenChannelAdapter<K,V>>

org.springframework.integration.kafka.dsl.KafkaShareMessageDrivenChannelAdapterSpec<K,V,S>

Type Parameters:

K - the key type.

V - the value type.

S - the target KafkaShareMessageDrivenChannelAdapterSpec implementation type.

All Implemented Interfaces:

DisposableBean, FactoryBean<KafkaShareMessageDrivenChannelAdapter<K,V>>, InitializingBean, Lifecycle, Phased, SmartLifecycle, ComponentsRegistration

Direct Known Subclasses:

KafkaShareMessageDrivenChannelAdapterSpec.KafkaShareMessageDrivenChannelAdapterListenerContainerSpec

public class KafkaShareMessageDrivenChannelAdapterSpec<K,V,S extends KafkaShareMessageDrivenChannelAdapterSpec<K,V,S>>
extends MessageProducerSpec<S,KafkaShareMessageDrivenChannelAdapter<K,V>>
implements ComponentsRegistration

A MessageProducerSpec implementation for the KafkaShareMessageDrivenChannelAdapter.

Since:

7.2

Author:

Artem Bilan

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	KafkaShareMessageDrivenChannelAdapterSpec.KafkaShareMessageDrivenChannelAdapterListenerContainerSpec<K,V>	A ShareKafkaMessageListenerContainer configuration KafkaShareMessageDrivenChannelAdapterSpec extension.

Field Summary

Fields inherited from class org.springframework.integration.dsl.IntegrationComponentSpec

logger, PARSER, target

Fields inherited from interface org.springframework.beans.factory.FactoryBean

OBJECT_TYPE_ATTRIBUTE

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Method Summary

Modifier and Type	Method	Description
S	bindSourceRecord(boolean bindSourceRecord)	Set to true to bind the source consumer record in the header named IntegrationMessageHeaderAccessor.SOURCE_DATA.
Map<Object,@Nullable String>	getComponentsToRegister()
S	payloadType(Class<?> payloadType)	When using a type-aware message converter (such as StringJsonMessageConverter), set the payload type the converter should create.
S	recordFilterStrategy(org.springframework.kafka.listener.adapter.RecordFilterStrategy<K,V> recordFilterStrategy)	Specify a RecordFilterStrategy to discard records before they are converted and sent.
S	recordMessageConverter(org.springframework.kafka.support.converter.RecordMessageConverter messageConverter)	Set the message converter to use.

Methods inherited from class org.springframework.integration.dsl.MessageProducerSpec

autoStartup, errorChannel, errorChannel, errorMessageStrategy, id, observationConvention, outputChannel, outputChannel, phase, role, sendTimeout, shouldTrack

Methods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec

_this, afterPropertiesSet, destroy, doGet, getId, getObject, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stop

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.beans.factory.FactoryBean

isSingleton

Methods inherited from interface org.springframework.context.SmartLifecycle

isPauseable

Method Details

recordMessageConverter

public S recordMessageConverter(org.springframework.kafka.support.converter.RecordMessageConverter messageConverter)

Set the message converter to use.

Parameters:

messageConverter - the converter.

Returns:

the spec.

recordFilterStrategy

public S recordFilterStrategy(org.springframework.kafka.listener.adapter.RecordFilterStrategy<K,V> recordFilterStrategy)

Specify a RecordFilterStrategy to discard records before they are converted and sent.

Parameters:

recordFilterStrategy - the RecordFilterStrategy to use.

Returns:

the spec.

payloadType

public S payloadType(Class<?> payloadType)

When using a type-aware message converter (such as StringJsonMessageConverter), set the payload type the converter should create. Defaults to Object.

Parameters:

payloadType - the type.

Returns:

the spec.

bindSourceRecord

public S bindSourceRecord(boolean bindSourceRecord)

Set to true to bind the source consumer record in the header named IntegrationMessageHeaderAccessor.SOURCE_DATA.

Parameters:

bindSourceRecord - true to bind.

Returns:

the spec.

getComponentsToRegister

public Map<Object,@Nullable String> getComponentsToRegister()

Specified by:

getComponentsToRegister in interface ComponentsRegistration