|
Spring Integration Kafka Support | ||||||||
PREV NEXT | FRAMES NO FRAMES |
Configuration
, storing the default topic and partitions explicitly.MessageListener
implementation that decodes the key and the payload using the supplied
Decoder
s.Configuration
where the seed brokers are set up explicitly.DefaultConnectionFactory
.SimpleConsumer
calls.ConnectionFactory
MessageListener
OffsetRequest.LatestTime()
) and -2 (OffsetRequest.LatestTime()
)
are used .
Partition
kafka message
and its metadata
.KafkaMessage
s retrieved by a fetch operationMessage
.OffsetManager
that persists offsets into a MetadataStore
.Partition
s.
MessageListener
s running.
minFetchSizeInBytes
) are available.
MetadataStore
for storing offsets.
maxWaitTimeInMs
has elapsed.
MessageListener
runner.
MetadataStore
Partition
Configuration
that uses a ZooKeeper connection for retrieving the list of seed brokers.
|
Spring Integration Kafka Support | ||||||||
PREV NEXT | FRAMES NO FRAMES |