|
Spring Integration Kafka Support | ||||||||
| PREV NEXT | FRAMES NO FRAMES | ||||||||
Configuration, storing the default topic and partitions,
as well as connectivity parameters.MessageListener implementation that decodes the key and the payload using the supplied
Decoders.OffsetManager.Configuration where the seed brokers are set up explicitly.DefaultConnectionFactory.SimpleConsumer calls.ConnectionFactoryPartition.
MessageListenerOffsetRequest.LatestTime()) and -2 (OffsetRequest.LatestTime())
are used .
minFetchSizeInBytes) are available.
maxWait has elapsed.
Partition
kafka message and its metadata.KafkaMessages retrieved by a fetch operationMessage.OffsetManager that uses a Kafka topic as the underlying support.Encoder and Decoder for Long values.OffsetManager that persists offsets into a MetadataStore.Partitions.
MessageListeners running.
minFetchSizeInBytes) are available.
MetadataStore for storing offsets.
maxWait has elapsed.
MessageListener runner.
Partition
Configuration that uses a ZooKeeper connection for retrieving the list of seed brokers.
|
Spring Integration Kafka Support | ||||||||
| PREV NEXT | FRAMES NO FRAMES | ||||||||