Package one.microstream.afs.kafka

Interface KafkaConnector

All Superinterfaces:

AutoCloseable, BlobStoreConnector

All Known Implementing Classes:

KafkaConnector.Default

public interface KafkaConnector
extends BlobStoreConnector

Connector for Apache Kafka.

First setup the connection properties.

 Properties properties = ...
 BlobStoreFileSystem fileSystem = BlobStoreFileSystem.New(
 KafkaConnector.New(properties)
 );
 

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	KafkaConnector.Default

Nested classes/interfaces inherited from interface one.microstream.afs.blobstore.BlobStoreConnector

BlobStoreConnector.Abstract<B>

Method Summary

Static Methods

Modifier and Type	Method	Description
static KafkaConnector	Caching(Properties kafkaProperties)	Pseudo-constructor method which creates a new KafkaConnector with cache.
static KafkaConnector	New(Properties kafkaProperties)	Pseudo-constructor method which creates a new KafkaConnector.

Methods inherited from interface one.microstream.afs.blobstore.BlobStoreConnector

close, copyFile, createDirectory, createFile, deleteFile, directoryExists, fileExists, fileSize, moveFile, readData, readData, truncateFile, visitChildren, writeData

Method Details

New

static KafkaConnector New(Properties kafkaProperties)

Pseudo-constructor method which creates a new KafkaConnector.

Parameters:

kafkaProperties - the Kafka configuration

Returns:

a new KafkaConnector

Caching

static KafkaConnector Caching(Properties kafkaProperties)

Pseudo-constructor method which creates a new KafkaConnector with cache.

Parameters:

kafkaProperties - the Kafka configuration

Returns:

a new KafkaConnector