Search Java Classes and Packages
#Org.springframework.integration.x.kafka Classes and Interfaces - 13 results found.
| Name | Description | Type | Package | Framework |
| AutoOffsetResetStrategy | enum AutoOffsetResetStrategyThe possible values for automatically resetting the offset of Kafka client | Class | org.springframework.integration.x.kafka | Spring XD |
| InitialOffsetsFactoryBean | Parses the list of initial offsets and creates a map to initialize the OffsetManagerAuthor:Marius Bogoevici, Ilayaperumal Gopinathan | Class | org.springframework.integration.x.kafka | Spring XD |
| KafkaConsumerOptionsMixin | Module options for Kafka consumer configuration. | Class | org.springframework.integration.x.kafka | Spring XD |
| KafkaMessageTransformer | A transformer that transforms the Kafka messages into Map of partition and payload. | Class | org.springframework.integration.x.kafka | Spring XD |
| KafkaOffsetTopicOptionsMixin | Class | org.springframework.integration.x.kafka | Spring XD | |
| KafkaPartitionAllocator | Is responsible for managing the partition allocation between multiple instances of a Kafka source moduledeployed in a stream. | Class | org.springframework.integration.x.kafka | Spring XD |
| KafkaProducerOptionsMixin | Module options for Kafka Producer configuration. | Class | org.springframework.integration.x.kafka | Spring XD |
| KafkaSinkModuleOptionsMetadata | Module options for Kafka sink module. | Class | org.springframework.integration.x.kafka | Spring XD |
| KafkaSourceModuleOptionsMetadata | Module options for Kafka source module. | Class | org.springframework.integration.x.kafka | Spring XD |
| KafkaSourceModuleOptionsMetadata .OffsetStorageStrategy | Class | org.springframework.integration.x.kafka.KafkaSourceModuleOptionsMetadata | Spring XD | |
| KafkaZKOptionMixin | Kafka module options mixin for ZK configuration. | Class | org.springframework.integration.x.kafka | Spring XD |
| NamespaceDelegatingMetadataStore | Wraps a delegate MetadataStore and adds a prefix to all the handled keys. | Class | org.springframework.integration.x.kafka | Spring XD |
| WindowingOffsetManager | An OffsetManager that aggregates writes over a time or count window, using an underlying delegate todo the actual operations. | Class | org.springframework.integration.x.kafka | Spring XD |