Kafka

<dependency>
	<groupId>org.eclipse.store</groupId>
	<artifactId>afs-kafka</artifactId>
	<version>2.1.0</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"));

Configuration

When using external configuration Kafka can be set as follows.

eclipsestore.properties

# optional, enforces checks
storage-filesystem.target=kafka

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

Supported properties

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

Depending on the amount of data and transactions, charges may apply depending on service usage. Please check with your service provider for details.