Apache Kafka Java APIs
MapR-ES supports these Apache Kafka Java APIs.
Javadoc
The following Admin APIs, org.apache.kafka.clients.admin
package, are
applicable to MapR support of Apache Kafka. These APIs are supported as of MapR
6.0.1.
- If the topic name is specified as
topic1
, then the API assumes the full topic path as/defaultStream:topic1
. - If the topic name is specified as
/defaultStream:topic1
, then that will be the full topic path.
AdminClient
default stream configuration parameter is
streams.admin.default.stream
. See Configuration Parameters for more information.Modifier and Type | Method |
---|---|
static AdminClient | create(java.util.Properties props) |
static AdminClient | create(java.util.Map<java.lang.String,java.lang.Object> conf) |
void | close() |
CreateTopicsResult | createTopics(java.util.Collection<NewTopic> newTopics) |
DeleteTopicsResult | deleteTopics(java.util.Collection<NewTopic> newTopics) |
DescribeTopicsResult | describeTopics(java.util.Collection<java.lang.String> topicNames) |
ListTopicsResult | listTopics() |
ListTopicsResult | listTopics((java.lang.String streamPath)) |
CreatePartitionsResult | createPartitions(java.util.Map<java.lang.String,NewPartitions> newPartitions) |
DescribeClusterResult | describeCluster() |
The following Consumer APIs, org.apache.kafka.clients.consumer
package,
are applicable to MapR support of Apache Kafka 1.1. These APIs are supported as of MapR
6.0.1.
Modifier and Type | Method |
---|---|
long | timestamp() |
long | timestamptype() |
Modifier and Type | Method |
---|---|
void | pause(Collection<TopicPartition> partitions) |
void | resume(Collection<TopicPartition>partitions) |
void | seekToBeginning(Collection<TopicPartition>) |
void | seekToEnd(Collection<TopicPartition>) |
void | subscribe(Collection<String> topics); |
void | subscribe(Collection<String> topics, ConsumerRebalanceListener) |
void | assign(Collection<TopicPartition> partitions) |
java.util.Map<TopicPartition,OffsetAndTimestamp> |
offsetsForTimes(java.util.Map<TopicPartition,java.lang.Long> timestampsToSearch) |
java.util.Map<TopicPartition,java.lang.Long> |
beginningOffsets(Collection<TopicPartition>) |
java.util.Map<TopicPartition,java.lang.Long> |
endOffsets(Collection<TopicPartition> partitions) |
ConsumerRecords<K,V> |
poll(long timeout) |
void |
commitSync() |
void |
commitAsync() |
The following consumer interface and classes are applicable to MapR support of Apache Kafka.
- 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>
The following producer interface and classes,
org.apache.kafka.clients.producer
package, are applicable to MapR
support of Apache Kafka 1.1. These APIs are supported as of MapR 6.0.1.
Modifier and Type | Method |
---|---|
java.util.concurrent.Future<RecordMetadata> | send(ProducerRecord<K,V> record) |
void | flush() |
void | close() |
The following producer interface and classes are applicable to MapR support of Apache Kafka 0.9.0.
- org.apache.kafka.clients.producer.Callback (Interface)
- org.apache.kafka.clients.producer.KafkaProducer<K,V>
- org.apache.kafka.clients.producer.ProducerConfig
- org.apache.kafka.clients.producer.ProducerRecord<K,V>
- org.apache.kafka.clients.producer.RecordMetadata
The following common APIs, org.apache.kafka.clients.common
packages, are
applicable to MapR support of Apache Kafka 1.0. These APIs are supported as of MapR
6.0.1.
Modifier and Type | Method |
---|---|
java.lang.String | key() |
byte[] | value() |
The following APIs are applicable to MapR support for Apache Kafka 0.9.0.
- org.apache.kafka.common.PartitionInfoSupported methods in PartitionInfo:
- int partition()
- java.lang.String topic()
- java.lang.String toString()
- org.apache.kafka.common.serialization.Serializer<T> (Interface)
- org.apache.kafka.common.serialization.Deserializer<T> (interface)
- org.apache.kafka.common.TopicPartition