Index

A B C D E F G H I J K L M N O P Q R S T U V W X Y Z _ 
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

K

Kafka - Class in org.springframework.integration.kafka.dsl
Factory class for Apache Kafka components.
KafkaAckCallback(KafkaMessageSource.KafkaAckInfo<K, V>, ConsumerProperties) - Constructor for class org.springframework.integration.kafka.inbound.KafkaMessageSource.KafkaAckCallback
Construct an instance with the provided properties.
KafkaAckCallbackFactory(ConsumerProperties) - Constructor for record class org.springframework.integration.kafka.inbound.KafkaMessageSource.KafkaAckCallbackFactory
Creates an instance of a KafkaAckCallbackFactory record class.
KafkaChannelParser - Class in org.springframework.integration.kafka.config.xml
Parser for a channel backed by an Apache Kafka topic.
KafkaChannelParser() - Constructor for class org.springframework.integration.kafka.config.xml.KafkaChannelParser
 
KafkaErrorSendingMessageRecoverer - Class in org.springframework.integration.kafka.inbound
An extension of ErrorMessagePublisher that can be used in a CommonErrorHandler for recovering Kafka delivery failures.
KafkaErrorSendingMessageRecoverer(MessageChannel) - Constructor for class org.springframework.integration.kafka.inbound.KafkaErrorSendingMessageRecoverer
Construct an instance to send to the channel with the RawRecordHeaderErrorMessageStrategy.
KafkaErrorSendingMessageRecoverer(MessageChannel, ErrorMessageStrategy) - Constructor for class org.springframework.integration.kafka.inbound.KafkaErrorSendingMessageRecoverer
Construct an instance to send the channel, using the error message strategy.
KafkaInboundChannelAdapterParser - Class in org.springframework.integration.kafka.config.xml
Parser for the inbound channel adapter.
KafkaInboundChannelAdapterParser() - Constructor for class org.springframework.integration.kafka.config.xml.KafkaInboundChannelAdapterParser
 
KafkaInboundChannelAdapterSpec<K,V> - Class in org.springframework.integration.kafka.dsl
Spec for a polled Apache Kafka inbound channel adapter.
KafkaInboundEndpoint - Interface in org.springframework.integration.kafka.inbound
Implementations of this interface will generally support a retry template for retrying incoming deliveries and this supports adding common attributes to the retry context.
KafkaInboundGateway<K,V,R> - Class in org.springframework.integration.kafka.inbound
Inbound gateway.
KafkaInboundGateway(AbstractMessageListenerContainer<K, V>, KafkaTemplate<K, R>) - Constructor for class org.springframework.integration.kafka.inbound.KafkaInboundGateway
Construct an instance with the provided container.
KafkaInboundGatewayParser - Class in org.springframework.integration.kafka.config.xml
Inbound gateway parser.
KafkaInboundGatewayParser() - Constructor for class org.springframework.integration.kafka.config.xml.KafkaInboundGatewayParser
 
KafkaInboundGatewaySpec<K,V,R,S extends KafkaInboundGatewaySpec<K,V,R,S>> - Class in org.springframework.integration.kafka.dsl
A MessagingGatewaySpec implementation for the KafkaInboundGateway.
KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec<K,V,R> - Class in org.springframework.integration.kafka.dsl
A ConcurrentMessageListenerContainer configuration KafkaInboundGatewaySpec extension.
KafkaIntegrationHeaders - Class in org.springframework.integration.kafka.support
Headers specifically for Spring Integration components.
KafkaMessageDrivenChannelAdapter<K,V> - Class in org.springframework.integration.kafka.inbound
Message-driven channel adapter.
KafkaMessageDrivenChannelAdapter(AbstractMessageListenerContainer<K, V>) - Constructor for class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter
KafkaMessageDrivenChannelAdapter(AbstractMessageListenerContainer<K, V>, KafkaMessageDrivenChannelAdapter.ListenerMode) - Constructor for class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter
Construct an instance with the provided mode.
KafkaMessageDrivenChannelAdapter.ListenerMode - Enum Class in org.springframework.integration.kafka.inbound
The listener mode for the container, record or batch.
KafkaMessageDrivenChannelAdapterParser - Class in org.springframework.integration.kafka.config.xml
Parser for the message driven channel adapter.
KafkaMessageDrivenChannelAdapterParser() - Constructor for class org.springframework.integration.kafka.config.xml.KafkaMessageDrivenChannelAdapterParser
 
KafkaMessageDrivenChannelAdapterSpec<K,V,S extends KafkaMessageDrivenChannelAdapterSpec<K,V,S>> - Class in org.springframework.integration.kafka.dsl
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V> - Class in org.springframework.integration.kafka.dsl
A ConcurrentMessageListenerContainer configuration KafkaMessageDrivenChannelAdapterSpec extension.
KafkaMessageListenerContainerSpec<K,V> - Class in org.springframework.integration.kafka.dsl
A helper class in the Builder pattern style to delegate options to the ConcurrentMessageListenerContainer.
KafkaMessageSource<K,V> - Class in org.springframework.integration.kafka.inbound
Polled message source for Apache Kafka.
KafkaMessageSource(ConsumerFactory<K, V>, ConsumerProperties) - Constructor for class org.springframework.integration.kafka.inbound.KafkaMessageSource
Construct an instance with the supplied parameters.
KafkaMessageSource(ConsumerFactory<K, V>, ConsumerProperties, boolean) - Constructor for class org.springframework.integration.kafka.inbound.KafkaMessageSource
Construct an instance with the supplied parameters.
KafkaMessageSource(ConsumerFactory<K, V>, ConsumerProperties, KafkaMessageSource.KafkaAckCallbackFactory<K, V>) - Constructor for class org.springframework.integration.kafka.inbound.KafkaMessageSource
Construct an instance with the supplied parameters.
KafkaMessageSource(ConsumerFactory<K, V>, ConsumerProperties, KafkaMessageSource.KafkaAckCallbackFactory<K, V>, boolean) - Constructor for class org.springframework.integration.kafka.inbound.KafkaMessageSource
Construct an instance with the supplied parameters.
KafkaMessageSource.KafkaAckCallback<K,V> - Class in org.springframework.integration.kafka.inbound
AcknowledgmentCallback for Kafka.
KafkaMessageSource.KafkaAckCallbackFactory<K,V> - Record Class in org.springframework.integration.kafka.inbound
AcknowledgmentCallbackFactory for KafkaAckInfo.
KafkaMessageSource.KafkaAckInfo<K,V> - Interface in org.springframework.integration.kafka.inbound
Information for building an KafkaAckCallback.
KafkaMessageSource.KafkaAckInfoImpl - Class in org.springframework.integration.kafka.inbound
Information for building an KafkaAckCallback.
KafkaNamespaceHandler - Class in org.springframework.integration.kafka.config.xml
The namespace handler for the Apache Kafka namespace.
KafkaNamespaceHandler() - Constructor for class org.springframework.integration.kafka.config.xml.KafkaNamespaceHandler
 
KafkaOutboundChannelAdapterParser - Class in org.springframework.integration.kafka.config.xml
Parser for the outbound channel adapter.
KafkaOutboundChannelAdapterParser() - Constructor for class org.springframework.integration.kafka.config.xml.KafkaOutboundChannelAdapterParser
 
KafkaOutboundGatewayParser - Class in org.springframework.integration.kafka.config.xml
Parser for the outbound gateway.
KafkaOutboundGatewayParser() - Constructor for class org.springframework.integration.kafka.config.xml.KafkaOutboundGatewayParser
 
KafkaOutboundGatewaySpec<K,V,R,S extends KafkaOutboundGatewaySpec<K,V,R,S>> - Class in org.springframework.integration.kafka.dsl
A MessageHandlerSpec implementation for the KafkaProducerMessageHandler as a gateway.
KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec<K,V,R> - Class in org.springframework.integration.kafka.dsl
A KafkaTemplate-based KafkaProducerMessageHandlerSpec extension.
KafkaOutboundGatewaySpec.ReplyingKafkaTemplateSpec<K,V,R> - Class in org.springframework.integration.kafka.dsl
An IntegrationComponentSpec implementation for the KafkaTemplate.
KafkaParsingUtils - Class in org.springframework.integration.kafka.config.xml
Utilities to assist with parsing XML.
KafkaPointToPointChannelSpec - Class in org.springframework.integration.kafka.dsl
Spec for a point to point channel backed by an Apache Kafka topic.
KafkaPointToPointChannelSpec(KafkaTemplate<?, ?>, KafkaListenerContainerFactory<?>, String) - Constructor for class org.springframework.integration.kafka.dsl.KafkaPointToPointChannelSpec
 
KafkaPollableChannelSpec - Class in org.springframework.integration.kafka.dsl
Spec for a pollable channel.
KafkaPollableChannelSpec(KafkaTemplate<?, ?>, KafkaMessageSource<?, ?>) - Constructor for class org.springframework.integration.kafka.dsl.KafkaPollableChannelSpec
 
KafkaProducerMessageHandler<K,V> - Class in org.springframework.integration.kafka.outbound
A Message Handler for Apache Kafka; when supplied with a ReplyingKafkaTemplate it is used as the handler in an outbound gateway.
KafkaProducerMessageHandler(KafkaTemplate<K, V>) - Constructor for class org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler
 
KafkaProducerMessageHandler.ProducerRecordCreator<K,V> - Interface in org.springframework.integration.kafka.outbound
Creates a ProducerRecord from a Message and/or properties derived from configuration and/or the message.
KafkaProducerMessageHandlerSpec<K,V,S extends KafkaProducerMessageHandlerSpec<K,V,S>> - Class in org.springframework.integration.kafka.dsl
KafkaProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec<K,V> - Class in org.springframework.integration.kafka.dsl
A KafkaTemplate-based KafkaProducerMessageHandlerSpec extension.
KafkaPublishSubscribeChannelSpec - Class in org.springframework.integration.kafka.dsl
Spec for a publish/subscribe channel backed by an Apache Kafka topic.
KafkaPublishSubscribeChannelSpec(KafkaTemplate<?, ?>, KafkaListenerContainerFactory<?>, String) - Constructor for class org.springframework.integration.kafka.dsl.KafkaPublishSubscribeChannelSpec
 
KafkaSendFailureException - Exception in org.springframework.integration.kafka.support
An exception that is the payload of an ErrorMessage when a send fails.
KafkaSendFailureException(Message<?>, ProducerRecord<?, ?>, Throwable) - Constructor for exception org.springframework.integration.kafka.support.KafkaSendFailureException
 
KafkaSubscribableChannelSpec<C extends SubscribableKafkaChannel> - Class in org.springframework.integration.kafka.dsl
Spec for a subscribable channel.
KafkaSubscribableChannelSpec() - Constructor for class org.springframework.integration.kafka.dsl.KafkaSubscribableChannelSpec
 
KafkaTemplateSpec<K,V> - Class in org.springframework.integration.kafka.dsl
An IntegrationComponentSpec implementation for the KafkaTemplate.
key - Variable in class org.springframework.integration.hazelcast.message.EntryEventMessagePayload
The entry key.
KEY - Enum constant in enum class org.springframework.integration.hazelcast.DistributedSQLIterationType
The IMap.keySet() to iterate.
KEY - Static variable in class org.springframework.integration.redis.metadata.RedisMetadataStore
 
KEY - Static variable in class org.springframework.integration.redis.support.RedisHeaders
 
KEY_TYPE_ID - Static variable in class org.springframework.integration.mapping.support.JsonHeaders
 
KeyDirectory(Object, String) - Constructor for class org.springframework.integration.file.remote.aop.RotationPolicy.KeyDirectory
 
keySet() - Method in class org.springframework.integration.expression.ExpressionEvalMap
 
KOTLIN_FUNCTION_0_CLASS - Static variable in class org.springframework.integration.util.ClassUtils
The kotlin.jvm.functions.Function0 class object.
KOTLIN_FUNCTION_0_INVOKE_METHOD - Static variable in class org.springframework.integration.util.ClassUtils
The kotlin.jvm.functions.Function0#invoke method object.
KOTLIN_FUNCTION_1_CLASS - Static variable in class org.springframework.integration.util.ClassUtils
The kotlin.jvm.functions.Function1 class object.
KotlinScriptExecutor - Class in org.springframework.integration.scripting.jsr223
Deprecated, for removal: This API element is subject to removal in a future version.
since 6.1.6 in favor of DefaultScriptExecutor with kotlin as an argument.
KotlinScriptExecutor() - Constructor for class org.springframework.integration.scripting.jsr223.KotlinScriptExecutor
Deprecated.
 
KRYO - Static variable in class org.springframework.integration.codec.kryo.AbstractKryoRegistrar
 
KryoClassListRegistrar - Class in org.springframework.integration.codec.kryo
A KryoRegistrar used to validateRegistration a list of Java classes.
KryoClassListRegistrar(Class<?>...) - Constructor for class org.springframework.integration.codec.kryo.KryoClassListRegistrar
 
KryoClassListRegistrar(List<Class<?>>) - Constructor for class org.springframework.integration.codec.kryo.KryoClassListRegistrar
 
KryoClassMapRegistrar - Class in org.springframework.integration.codec.kryo
A KryoRegistrar implementation backed by a Map used to explicitly set the registration ID for each class.
KryoClassMapRegistrar(Map<Integer, Class<?>>) - Constructor for class org.springframework.integration.codec.kryo.KryoClassMapRegistrar
 
KryoRegistrar - Interface in org.springframework.integration.codec.kryo
Strategy interface used by PojoCodec to configure registrations classes consistently across Kryo instances.
KryoRegistrationRegistrar - Class in org.springframework.integration.codec.kryo
A KryoRegistrar implementation backed by a List of Registration.
KryoRegistrationRegistrar(List<Registration>) - Constructor for class org.springframework.integration.codec.kryo.KryoRegistrationRegistrar
 
A B C D E F G H I J K L M N O P Q R S T U V W X Y Z _ 
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form