Kafka

<dependency>
	<groupId>one.microstream</groupId>
	<artifactId>microstream-afs-kafka</artifactId>
	<version>08.01.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"));