|
|||||||||
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
Decoder
s.OffsetManager
.Configuration
where the seed brokers are set up explicitly.DefaultConnectionFactory
.SimpleConsumer
calls.ConnectionFactory
Partition
.
MessageListener
OffsetRequest.LatestTime()
) and -2 (OffsetRequest.LatestTime()
)
are used .
minFetchSizeInBytes
) are available.
maxWait
has elapsed.
Partition
kafka message
and its metadata
.KafkaMessage
s 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
.Partition
s.
MessageListener
s 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.
|
|||||||||
PREV NEXT | FRAMES NO FRAMES |