- commitOffsets() - Method in interface kafka.javaapi.consumer.ConsumerConnector
-
Commit the offsets of all broker partitions connected by this connector.
- commitOffsets(boolean) - Method in interface kafka.javaapi.consumer.ConsumerConnector
-
- ConsumerConnector - Interface in kafka.javaapi.consumer
-
- Crc32 - Class in kafka.utils
-
This class was taken from Hadoop org.apache.hadoop.util.PureJavaCrc32
A pure-java implementation of the CRC32 checksum that uses
the same polynomial as the built-in native CRC32.
- Crc32() - Constructor for class kafka.utils.Crc32
-
Create a new PureJavaCrc32 object.
- createMessageStreams(Map<String, Integer>, Decoder<K>, Decoder<V>) - Method in interface kafka.javaapi.consumer.ConsumerConnector
-
Create a list of MessageStreams of type T for each topic.
- createMessageStreams(Map<String, Integer>) - Method in interface kafka.javaapi.consumer.ConsumerConnector
-
- createMessageStreamsByFilter(TopicFilter, int, Decoder<K>, Decoder<V>) - Method in interface kafka.javaapi.consumer.ConsumerConnector
-
Create a list of MessageAndTopicStreams containing messages of type T.
- createMessageStreamsByFilter(TopicFilter, int) - Method in interface kafka.javaapi.consumer.ConsumerConnector
-
- createMessageStreamsByFilter(TopicFilter) - Method in interface kafka.javaapi.consumer.ConsumerConnector
-