KAFKA-1743: This method added for backward compatibility.
Commit the offsets of all broker partitions connected by this connector.
Create a list of MessageStreams for each topic.
Create a list of MessageStreams for each topic.
a map of (topic, #streams) pair
Decoder to decode the key portion of the message
Decoder to decode the value portion of the message
a map of (topic, list of KafkaStream) pairs. The number of items in the list is #streams. Each stream supports an iterator over message/metadata pairs.
Create a list of MessageStreams for each topic.
Create a list of MessageStreams for each topic.
a map of (topic, #streams) pair
a map of (topic, list of KafkaStream) pairs. The number of items in the list is #streams. Each stream supports an iterator over message/metadata pairs.
Create a list of message streams for all topics that match a given filter.
Create a list of message streams for all topics that match a given filter.
Either a Whitelist or Blacklist TopicFilter object.
Number of streams to return
Decoder to decode the key portion of the message
Decoder to decode the value portion of the message
a list of KafkaStream each of which provides an iterator over message/metadata pairs over allowed topics.
Shut down the connector
Main interface for consumer