Uses of Class
org.springframework.integration.kafka.dsl.KafkaInboundGatewaySpec
Package
Description
Provides Spring Integration Java DSL Components support for Apache Kafka.
-
Uses of KafkaInboundGatewaySpec in org.springframework.integration.kafka.dsl
Modifier and TypeClassDescriptionclass
KafkaInboundGatewaySpec<K,
V, R, S extends KafkaInboundGatewaySpec<K, V, R, S>> AMessagingGatewaySpec
implementation for theKafkaInboundGateway
.Modifier and TypeClassDescriptionstatic class
AConcurrentMessageListenerContainer
configurationKafkaInboundGatewaySpec
extension.Modifier and TypeMethodDescriptionstatic <K,
V, R> KafkaInboundGatewaySpec<K, V, R, ?> Kafka.inboundGateway
(org.springframework.kafka.listener.AbstractMessageListenerContainer<K, V> container, org.springframework.kafka.core.KafkaTemplate<K, R> template) Create an initialKafkaInboundGatewaySpec
with the provided container and template.