Package org.springframework.integration.kafka.dsl

Class KafkaInboundGatewaySpec<K,V,R,S extends KafkaInboundGatewaySpec<K,V,R,S>>

java.lang.Object

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

org.springframework.integration.dsl.MessagingGatewaySpec<S,KafkaInboundGateway<K,V,R>>

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

Type Parameters:

K - the key type.

V - the request value type.

R - the reply value type.

S - the target KafkaInboundGatewaySpec implementation type.

All Implemented Interfaces:

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

Direct Known Subclasses:

KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec

public class KafkaInboundGatewaySpec<K,V,R,S extends KafkaInboundGatewaySpec<K,V,R,S>>
extends MessagingGatewaySpec<S,KafkaInboundGateway<K,V,R>>
implements ComponentsRegistration

A MessagingGatewaySpec implementation for the KafkaInboundGateway.

Since:

5.4

Author:

Gary Russell, Artem Bilan

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec<K,V,R>	A ConcurrentMessageListenerContainer configuration KafkaInboundGatewaySpec 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
Map<Object,String>	getComponentsToRegister()
S	messageConverter(org.springframework.kafka.support.converter.RecordMessageConverter messageConverter)	Set the message converter to use with a record-based consumer.
S	onPartitionsAssignedSeekCallback(BiConsumer<Map<org.apache.kafka.common.TopicPartition,Long>,org.springframework.kafka.listener.ConsumerSeekAware.ConsumerSeekCallback> onPartitionsAssignedCallback)	Specify a BiConsumer for seeks management during ConsumerSeekAware.onPartitionsAssigned(Map, ConsumerSeekAware.ConsumerSeekCallback) call from the KafkaMessageListenerContainer.
S	recoveryCallback(org.springframework.retry.RecoveryCallback<?> recoveryCallback)	A RecoveryCallback instance for retry operation; if null, the exception will be thrown to the container after retries are exhausted.
S	retryTemplate(org.springframework.retry.support.RetryTemplate retryTemplate)	Specify a RetryTemplate instance to use for retrying deliveries.

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

autoStartup, errorChannel, errorChannel, errorOnTimeout, id, observationConvention, phase, replyChannel, replyChannel, replyMapper, replyTimeout, requestChannel, requestChannel, requestMapper, requestTimeout, shouldTrack

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

_this, afterPropertiesSet, destroy, doGet, get, 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

Method Details

messageConverter

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

Set the message converter to use with a record-based consumer.

Parameters:

messageConverter - the converter.

Returns:

the spec

retryTemplate

public S retryTemplate(org.springframework.retry.support.RetryTemplate retryTemplate)

Specify a RetryTemplate instance to use for retrying deliveries.

Parameters:

retryTemplate - the RetryTemplate to use.

Returns:

the spec

recoveryCallback

public S recoveryCallback(org.springframework.retry.RecoveryCallback<?> recoveryCallback)

A RecoveryCallback instance for retry operation; if null, the exception will be thrown to the container after retries are exhausted. Does not make sense if retryTemplate(RetryTemplate) isn't specified.

Parameters:

recoveryCallback - the recovery callback.

Returns:

the spec

onPartitionsAssignedSeekCallback

public S onPartitionsAssignedSeekCallback(BiConsumer<Map<org.apache.kafka.common.TopicPartition,Long>,org.springframework.kafka.listener.ConsumerSeekAware.ConsumerSeekCallback> onPartitionsAssignedCallback)

Specify a BiConsumer for seeks management during ConsumerSeekAware.onPartitionsAssigned(Map, ConsumerSeekAware.ConsumerSeekCallback) call from the KafkaMessageListenerContainer.

Parameters:

onPartitionsAssignedCallback - the BiConsumer to use

Returns:

the spec

getComponentsToRegister

public Map<Object,String> getComponentsToRegister()

Specified by:

getComponentsToRegister in interface ComponentsRegistration