Kafka

This is an enterprise feature.

<dependency>
	<groupId>one.microstream</groupId>
	<artifactId>microstream-enterprise-afs-kafka</artifactId>
	<version>05.00.02-MS-GA</version>
</dependency>

Properties properties = new Properties();
properties.setProperty(
	CommonClientConfigs.BOOTSTRAP_SERVERS_CONFIG,
	"localhost:9093"
);
BlobStoreFileSystem fileSystem = BlobStoreFileSystem.New(
	KafkaConnector.Caching(properties)
);
EmbeddedStorage.start(fileSystem.ensureDirectoryPath("microstream_storage"));

Configuration

When using external configuration Kafka can be set as follows.

microstream-storage.properties

storage-filesystem.kafka-properties.bootstrap.servers=localhost:9093

Supported properties

All supported properties of Kafka, see https://kafka.apache.org/documentation/