From dcc167a4ddfeee16eb38c5ed81ef4f4b35e7dbdd Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?S=C3=B6ren=20Henning?= <soeren.henning@email.uni-kiel.de> Date: Wed, 5 Jan 2022 15:06:18 +0100 Subject: [PATCH] Cleanup Samza properties files --- .../samza-standalone.properties | 18 +++++++---------- .../samza-standalone.properties | 18 +++++++---------- .../samza-standalone.properties | 18 +++++++---------- .../samza-standalone.properties | 20 ++++++++----------- 4 files changed, 29 insertions(+), 45 deletions(-) diff --git a/theodolite-benchmarks/uc1-beam-samza/samza-standalone.properties b/theodolite-benchmarks/uc1-beam-samza/samza-standalone.properties index 8044fe3d7..4e40e0119 100644 --- a/theodolite-benchmarks/uc1-beam-samza/samza-standalone.properties +++ b/theodolite-benchmarks/uc1-beam-samza/samza-standalone.properties @@ -1,17 +1,13 @@ -# runner -app.runner.class=org.apache.samza.runtime.LocalApplicationRunner - -# zk +# Configure ZooKeeper for coordination job.coordinator.factory=org.apache.samza.zk.ZkJobCoordinatorFactory -#job.coordinator.zk.connect=my-confluent-cp-zookeeper:2181 -job.coordinator.zk.connect=zookeeper:2181 +job.coordinator.zk.connect=localhost:2181 + +# Use GroupByContainerIds task.name.grouper.factory=org.apache.samza.container.grouper.task.GroupByContainerIdsFactory -# default system +# Configure Kafka as "system" job.default.system=kafka systems.kafka.samza.factory=org.apache.samza.system.kafka.KafkaSystemFactory -systems.kafka.consumer.zookeeper.connect=zookeeper:2181 -#systems.kafka.consumer.zookeeper.connect=my-confluent-cp-zookeeper:2181 -systems.kafka.producer.bootstrap.servers=kafka:9092 -#systems.kafka.producer.bootstrap.servers=my-confluent-cp-kafka:9092 +systems.kafka.consumer.bootstrap.servers=localhost:9092 +systems.kafka.producer.bootstrap.servers=localhost:9092 systems.kafka.default.stream.replication.factor=1 diff --git a/theodolite-benchmarks/uc2-beam-samza/samza-standalone.properties b/theodolite-benchmarks/uc2-beam-samza/samza-standalone.properties index 8044fe3d7..4e40e0119 100644 --- a/theodolite-benchmarks/uc2-beam-samza/samza-standalone.properties +++ b/theodolite-benchmarks/uc2-beam-samza/samza-standalone.properties @@ -1,17 +1,13 @@ -# runner -app.runner.class=org.apache.samza.runtime.LocalApplicationRunner - -# zk +# Configure ZooKeeper for coordination job.coordinator.factory=org.apache.samza.zk.ZkJobCoordinatorFactory -#job.coordinator.zk.connect=my-confluent-cp-zookeeper:2181 -job.coordinator.zk.connect=zookeeper:2181 +job.coordinator.zk.connect=localhost:2181 + +# Use GroupByContainerIds task.name.grouper.factory=org.apache.samza.container.grouper.task.GroupByContainerIdsFactory -# default system +# Configure Kafka as "system" job.default.system=kafka systems.kafka.samza.factory=org.apache.samza.system.kafka.KafkaSystemFactory -systems.kafka.consumer.zookeeper.connect=zookeeper:2181 -#systems.kafka.consumer.zookeeper.connect=my-confluent-cp-zookeeper:2181 -systems.kafka.producer.bootstrap.servers=kafka:9092 -#systems.kafka.producer.bootstrap.servers=my-confluent-cp-kafka:9092 +systems.kafka.consumer.bootstrap.servers=localhost:9092 +systems.kafka.producer.bootstrap.servers=localhost:9092 systems.kafka.default.stream.replication.factor=1 diff --git a/theodolite-benchmarks/uc3-beam-samza/samza-standalone.properties b/theodolite-benchmarks/uc3-beam-samza/samza-standalone.properties index 8044fe3d7..4e40e0119 100644 --- a/theodolite-benchmarks/uc3-beam-samza/samza-standalone.properties +++ b/theodolite-benchmarks/uc3-beam-samza/samza-standalone.properties @@ -1,17 +1,13 @@ -# runner -app.runner.class=org.apache.samza.runtime.LocalApplicationRunner - -# zk +# Configure ZooKeeper for coordination job.coordinator.factory=org.apache.samza.zk.ZkJobCoordinatorFactory -#job.coordinator.zk.connect=my-confluent-cp-zookeeper:2181 -job.coordinator.zk.connect=zookeeper:2181 +job.coordinator.zk.connect=localhost:2181 + +# Use GroupByContainerIds task.name.grouper.factory=org.apache.samza.container.grouper.task.GroupByContainerIdsFactory -# default system +# Configure Kafka as "system" job.default.system=kafka systems.kafka.samza.factory=org.apache.samza.system.kafka.KafkaSystemFactory -systems.kafka.consumer.zookeeper.connect=zookeeper:2181 -#systems.kafka.consumer.zookeeper.connect=my-confluent-cp-zookeeper:2181 -systems.kafka.producer.bootstrap.servers=kafka:9092 -#systems.kafka.producer.bootstrap.servers=my-confluent-cp-kafka:9092 +systems.kafka.consumer.bootstrap.servers=localhost:9092 +systems.kafka.producer.bootstrap.servers=localhost:9092 systems.kafka.default.stream.replication.factor=1 diff --git a/theodolite-benchmarks/uc4-beam-samza/samza-standalone.properties b/theodolite-benchmarks/uc4-beam-samza/samza-standalone.properties index 6f1f1aa65..fc8e4a196 100644 --- a/theodolite-benchmarks/uc4-beam-samza/samza-standalone.properties +++ b/theodolite-benchmarks/uc4-beam-samza/samza-standalone.properties @@ -1,22 +1,18 @@ -# runner -app.runner.class=org.apache.samza.runtime.LocalApplicationRunner - -# zk +# Configure ZooKeeper for coordination job.coordinator.factory=org.apache.samza.zk.ZkJobCoordinatorFactory -#job.coordinator.zk.connect=my-confluent-cp-zookeeper:2181 -job.coordinator.zk.connect=zookeeper:2181 +job.coordinator.zk.connect=localhost:2181 + +# Use GroupByContainerIds task.name.grouper.factory=org.apache.samza.container.grouper.task.GroupByContainerIdsFactory -# default system +# Configure Kafka as "system" job.default.system=kafka systems.kafka.samza.factory=org.apache.samza.system.kafka.KafkaSystemFactory -systems.kafka.consumer.zookeeper.connect=zookeeper:2181 -#systems.kafka.consumer.zookeeper.connect=my-confluent-cp-zookeeper:2181 -systems.kafka.producer.bootstrap.servers=kafka:9092 -#systems.kafka.producer.bootstrap.servers=my-confluent-cp-kafka:9092 +systems.kafka.consumer.bootstrap.servers=localhost:9092 +systems.kafka.producer.bootstrap.servers=localhost:9092 systems.kafka.default.stream.replication.factor=1 - +# Configure serialization and stores serializers.registry.string.class=org.apache.samza.serializers.StringSerdeFactory stores.my-store.factory=org.apache.samza.storage.kv.RocksDbKeyValueStorageEngineFactory stores.my-store.key.serde=string -- GitLab