K
- the key type.V
- the value type.public class Kafka09MessageDrivenChannelAdapter<K,V>
extends org.springframework.integration.endpoint.MessageProducerSupport
implements org.springframework.integration.context.OrderlyShutdownCapable
org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter
from Spring Integration Kafka 2.0, since we can't upgrade to spring-integration-kafka-2.0
.Constructor and Description |
---|
Kafka09MessageDrivenChannelAdapter(org.springframework.kafka.listener.AbstractMessageListenerContainer<K,V> messageListenerContainer) |
Modifier and Type | Method and Description |
---|---|
int |
afterShutdown() |
int |
beforeShutdown() |
protected void |
doStart() |
protected void |
doStop() |
java.lang.String |
getComponentType() |
protected void |
onInit() |
void |
setAckDiscarded(boolean ackDiscarded) |
void |
setFilterInRetry(boolean filterInRetry) |
void |
setMessageConverter(org.springframework.kafka.support.converter.MessageConverter messageConverter) |
void |
setRecordFilterStrategy(org.springframework.kafka.listener.adapter.RecordFilterStrategy<K,V> recordFilterStrategy) |
void |
setRecoveryCallback(org.springframework.retry.RecoveryCallback<java.lang.Void> recoveryCallback) |
void |
setRetryTemplate(org.springframework.retry.support.RetryTemplate retryTemplate) |
afterSingletonsInstantiated, getErrorChannel, getMessagingTemplate, getOutputChannel, sendMessage, setErrorChannel, setErrorChannelName, setOutputChannel, setOutputChannelName, setSendTimeout, setShouldTrack
doStop, getPhase, isAutoStartup, isRunning, setAutoStartup, setPhase, setTaskScheduler, start, stop, stop
afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, toString
public void setMessageConverter(org.springframework.kafka.support.converter.MessageConverter messageConverter)
public void setRecordFilterStrategy(org.springframework.kafka.listener.adapter.RecordFilterStrategy<K,V> recordFilterStrategy)
public void setAckDiscarded(boolean ackDiscarded)
public void setRetryTemplate(org.springframework.retry.support.RetryTemplate retryTemplate)
public void setRecoveryCallback(org.springframework.retry.RecoveryCallback<java.lang.Void> recoveryCallback)
public void setFilterInRetry(boolean filterInRetry)
protected void onInit()
onInit
in class org.springframework.integration.endpoint.MessageProducerSupport
protected void doStart()
doStart
in class org.springframework.integration.endpoint.MessageProducerSupport
protected void doStop()
doStop
in class org.springframework.integration.endpoint.MessageProducerSupport
public java.lang.String getComponentType()
getComponentType
in interface org.springframework.integration.support.context.NamedComponent
getComponentType
in class org.springframework.integration.context.IntegrationObjectSupport
public int beforeShutdown()
beforeShutdown
in interface org.springframework.integration.context.OrderlyShutdownCapable
public int afterShutdown()
afterShutdown
in interface org.springframework.integration.context.OrderlyShutdownCapable