Apache Kafka Java APIs
HPE Ezmeral Data Fabric Streams supports these Apache Kafka Java APIs.
Javadoc
In HPE Ezmeral Data Fabric 7.0, Apache Kafka 2.6.1 is supported.
EEP 8.1.0 supports Apache Kafka 2.6.1.
- HPE Ezmeral Data Fabric Streams Java API Library
- Apache Kafka 2.6.1 APIs used with HPE Ezmeral Data Fabric StreamsNOTE The Apache Kafka 2.1 APIs are also supported in Apache Kafka 2.6.1.
The following Admin APIs, org.apache.kafka.clients.admin
package, are
applicable to HPE Ezmeral Data Fabric
support of Apache Kafka.
- 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.The following Consumer APIs, org.apache.kafka.clients.consumer
package,
are applicable to HPE Ezmeral Data Fabric support of Apache Kafka 2.1 and 2.6.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 HPE Ezmeral Data Fabric 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 HPE Ezmeral Data Fabric support of Apache
Kafka 2.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 HPE Ezmeral Data Fabric support of Apache Kafka.
- 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 toHPE Ezmeral Data Fabric
support of Apache Kafka 2.1. .
Modifier and Type | Method |
---|---|
java.lang.String | key() |
byte[] | value() |
The following APIs are applicable to HPE Ezmeral Data Fabric support for Apache Kafka.
- 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