Supported Apache Kafka 0.90 Java APIs for Consumers
MapR Streams supports these classes and interfaces for consumers.
- org.apache.kafka.clients.consumer.ConsumerConfig
- org.apache.kafka.clients.consumer.ConsumerRebalanceCallback (interface)
- org.apache.kafka.clients.consumer.ConsumerRecord<K,V>
- org.apache.kafka.clients.consumer.ConsumerRecords<K,V>
- org.apache.kafka.clients.consumer.KafkaConsumer<K, V> implements Consumer<K, V>
- org.apache.kafka.common.serialization.Deserializer<T> (interface)
See the Javadoc for details about these classes and interfaces.