Package one.microstream.afs.kafka

Interface TopicIndex

All Superinterfaces:

AutoCloseable

All Known Implementing Classes:

TopicIndex.Default

public interface TopicIndex
extends AutoCloseable

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	TopicIndex.Default

Method Summary

Modifier and Type	Method	Description
void	close()
TopicIndex	delete(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.admin.RecordsToDelete> recordsToDelete)
Iterable<Blob>	get()
static TopicIndex	New(Properties kafkaProperties, String topic)
TopicIndex	put(Iterable<Blob> blobs)

Method Details

get

Iterable<Blob> get()

put

TopicIndex put(Iterable<Blob> blobs)

delete

TopicIndex delete(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.admin.RecordsToDelete> recordsToDelete)

close

void close()

Specified by:

close in interface AutoCloseable

New

static TopicIndex New(Properties kafkaProperties, String topic)