Kafka

<dependency>
	<groupId>org.eclipse.store</groupId>
	<artifactId>afs-kafka</artifactId>
	<version>1.3.2</version>
</dependency>
<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka-clients</artifactId>
    <version>3.1.2</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("storage"));