Apache Kafka Java APIs
HPE Ezmeral Data Fabric Streams supports these Apache Kafka Java APIs.
Javadoc
For information about EEP and core version support, see EEP Support and Lifecycle Status.
- HPE Ezmeral Data Fabric Streams Java API Library
- For core 7.8 and above: Apache Kafka 3.6.1 APIs used with HPE Ezmeral Data Fabric Streams
- For core 7.7 and below: Apache Kafka 2.6.1 APIs used with HPE Ezmeral Data Fabric Streams
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.- For core 7.8 and above: Apache Kafka 3.6.1 APIs used with HPE Ezmeral Data Fabric Streams
- For core 7.7 and below: Apache Kafka 2.6.1 APIs used with HPE Ezmeral Data Fabric Streams
The following Consumer APIs, org.apache.kafka.clients.consumer
package,
are applicable to HPE Ezmeral Data Fabric support of Apache Kafka.
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>
- For core 7.8 and above: Apache Kafka 3.6.1 APIs used with HPE Ezmeral Data Fabric Streams
- For core 7.7 and below: Apache Kafka 2.6.1 APIs used with HPE Ezmeral Data Fabric Streams
The following producer interface and classes,
org.apache.kafka.clients.producer
package, are applicable to HPE Ezmeral Data Fabric support of Apache
Kafka.
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
- For core 7.8 and above: Apache Kafka 3.6.1 APIs used with HPE Ezmeral Data Fabric Streams
- For core 7.7 and below: Apache Kafka 2.6.1 APIs used with HPE Ezmeral Data Fabric Streams
The following common APIs, org.apache.kafka.clients.common
packages, are
applicable toHPE Ezmeral Data Fabric
support of Apache Kafka.
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
- For core 7.8 and above: Apache Kafka 3.6.1 APIs used with HPE Ezmeral Data Fabric Streams
- For core 7.7 and below: Apache Kafka 2.6.1 APIs used with HPE Ezmeral Data Fabric Streams