{
return new FilesStorageStrategy(
Paths.get("target", "test-classes", "data", "files"),
new KafkaLikeShardingStrategy(NUM_SHARDS),
{
return new FilesStorageStrategy(
Paths.get("target", "test-classes", "data", "files"),
new KafkaLikeShardingStrategy(NUM_SHARDS),