Uses of Interface
one.microstream.afs.kafka.TopicIndex
Package | Description |
---|---|
one.microstream.afs.kafka |
-
Uses of TopicIndex in one.microstream.afs.kafka
Classes in one.microstream.afs.kafka that implement TopicIndex Modifier and Type Class Description static class
TopicIndex.Default
Methods in one.microstream.afs.kafka that return TopicIndex Modifier and Type Method Description TopicIndex
TopicIndex.Default. delete(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.admin.RecordsToDelete> recordsToDelete)
TopicIndex
TopicIndex. delete(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.admin.RecordsToDelete> recordsToDelete)
static TopicIndex
TopicIndex. New(Properties kafkaProperties, String topic)
TopicIndex
TopicIndex.Default. put(Iterable<Blob> metadata)
TopicIndex
TopicIndex. put(Iterable<Blob> blobs)