|
|||||||||
| PREV NEXT | FRAMES NO FRAMES | ||||||||
Configuration, storing the default topic and partitions,
as well as connectivity parameters.AcknowledgingMessageListener implementation that decodes the key and the
payload using the supplied Decoders.MessageListener implementation that decodes the key and the payload using the supplied
Decoders.OffsetManager.KafkaMessage.Configuration where the seed brokers are set up explicitly.DefaultConnectionFactory.SimpleConsumer calls.Acknowledgment that defers to an underlying
OffsetManager.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.
Message ids for produced messages.
timestamp for produced messages.
minFetchSizeInBytes) are available.
MetadataStore for storing offsets.
maxWait has elapsed.
MessageListener runner.
MessageBuilderFactory returned by IntegrationObjectSupport.getMessageBuilderFactory() to create messages.
Partition
Configuration that uses a ZooKeeper connection for retrieving the list of seed brokers.
|
|||||||||
| PREV NEXT | FRAMES NO FRAMES | ||||||||