Skip to content
Snippets Groups Projects
Commit dcc167a4 authored by Sören Henning's avatar Sören Henning
Browse files

Cleanup Samza properties files

parent 1a6a0917
No related branches found
No related tags found
1 merge request!187Migrate Beam benchmark implementation
Pipeline #5826 passed
Stage: build
Stage: test
Stage: check
Hide whitespace changes
Inline Side-by-side
theodolite-benchmarks/uc1-beam-samza/samza-standalone.properties
+ 7
− 11
View file @ dcc167a4
# runner # Configure ZooKeeper for coordination
app.runner.class=org.apache.samza.runtime.LocalApplicationRunner
# zk
job.coordinator.factory=org.apache.samza.zk.ZkJobCoordinatorFactory job.coordinator.factory=org.apache.samza.zk.ZkJobCoordinatorFactory
#job.coordinator.zk.connect=my-confluent-cp-zookeeper:2181 job.coordinator.zk.connect=localhost:2181
job.coordinator.zk.connect=zookeeper:2181
# Use GroupByContainerIds
task.name.grouper.factory=org.apache.samza.container.grouper.task.GroupByContainerIdsFactory task.name.grouper.factory=org.apache.samza.container.grouper.task.GroupByContainerIdsFactory
# default system # Configure Kafka as "system"
job.default.system=kafka job.default.system=kafka
systems.kafka.samza.factory=org.apache.samza.system.kafka.KafkaSystemFactory systems.kafka.samza.factory=org.apache.samza.system.kafka.KafkaSystemFactory
systems.kafka.consumer.zookeeper.connect=zookeeper:2181 systems.kafka.consumer.bootstrap.servers=localhost:9092
#systems.kafka.consumer.zookeeper.connect=my-confluent-cp-zookeeper:2181 systems.kafka.producer.bootstrap.servers=localhost:9092
systems.kafka.producer.bootstrap.servers=kafka:9092
#systems.kafka.producer.bootstrap.servers=my-confluent-cp-kafka:9092
systems.kafka.default.stream.replication.factor=1 systems.kafka.default.stream.replication.factor=1
theodolite-benchmarks/uc2-beam-samza/samza-standalone.properties
+ 7
− 11
View file @ dcc167a4
# runner # Configure ZooKeeper for coordination
app.runner.class=org.apache.samza.runtime.LocalApplicationRunner
# zk
job.coordinator.factory=org.apache.samza.zk.ZkJobCoordinatorFactory job.coordinator.factory=org.apache.samza.zk.ZkJobCoordinatorFactory
#job.coordinator.zk.connect=my-confluent-cp-zookeeper:2181 job.coordinator.zk.connect=localhost:2181
job.coordinator.zk.connect=zookeeper:2181
# Use GroupByContainerIds
task.name.grouper.factory=org.apache.samza.container.grouper.task.GroupByContainerIdsFactory task.name.grouper.factory=org.apache.samza.container.grouper.task.GroupByContainerIdsFactory
# default system # Configure Kafka as "system"
job.default.system=kafka job.default.system=kafka
systems.kafka.samza.factory=org.apache.samza.system.kafka.KafkaSystemFactory systems.kafka.samza.factory=org.apache.samza.system.kafka.KafkaSystemFactory
systems.kafka.consumer.zookeeper.connect=zookeeper:2181 systems.kafka.consumer.bootstrap.servers=localhost:9092
#systems.kafka.consumer.zookeeper.connect=my-confluent-cp-zookeeper:2181 systems.kafka.producer.bootstrap.servers=localhost:9092
systems.kafka.producer.bootstrap.servers=kafka:9092
#systems.kafka.producer.bootstrap.servers=my-confluent-cp-kafka:9092
systems.kafka.default.stream.replication.factor=1 systems.kafka.default.stream.replication.factor=1
theodolite-benchmarks/uc3-beam-samza/samza-standalone.properties
+ 7
− 11
View file @ dcc167a4
# runner # Configure ZooKeeper for coordination
app.runner.class=org.apache.samza.runtime.LocalApplicationRunner
# zk
job.coordinator.factory=org.apache.samza.zk.ZkJobCoordinatorFactory job.coordinator.factory=org.apache.samza.zk.ZkJobCoordinatorFactory
#job.coordinator.zk.connect=my-confluent-cp-zookeeper:2181 job.coordinator.zk.connect=localhost:2181
job.coordinator.zk.connect=zookeeper:2181
# Use GroupByContainerIds
task.name.grouper.factory=org.apache.samza.container.grouper.task.GroupByContainerIdsFactory task.name.grouper.factory=org.apache.samza.container.grouper.task.GroupByContainerIdsFactory
# default system # Configure Kafka as "system"
job.default.system=kafka job.default.system=kafka
systems.kafka.samza.factory=org.apache.samza.system.kafka.KafkaSystemFactory systems.kafka.samza.factory=org.apache.samza.system.kafka.KafkaSystemFactory
systems.kafka.consumer.zookeeper.connect=zookeeper:2181 systems.kafka.consumer.bootstrap.servers=localhost:9092
#systems.kafka.consumer.zookeeper.connect=my-confluent-cp-zookeeper:2181 systems.kafka.producer.bootstrap.servers=localhost:9092
systems.kafka.producer.bootstrap.servers=kafka:9092
#systems.kafka.producer.bootstrap.servers=my-confluent-cp-kafka:9092
systems.kafka.default.stream.replication.factor=1 systems.kafka.default.stream.replication.factor=1
theodolite-benchmarks/uc4-beam-samza/samza-standalone.properties
+ 8
− 12
View file @ dcc167a4
# runner # Configure ZooKeeper for coordination
app.runner.class=org.apache.samza.runtime.LocalApplicationRunner
# zk
job.coordinator.factory=org.apache.samza.zk.ZkJobCoordinatorFactory job.coordinator.factory=org.apache.samza.zk.ZkJobCoordinatorFactory
#job.coordinator.zk.connect=my-confluent-cp-zookeeper:2181 job.coordinator.zk.connect=localhost:2181
job.coordinator.zk.connect=zookeeper:2181
# Use GroupByContainerIds
task.name.grouper.factory=org.apache.samza.container.grouper.task.GroupByContainerIdsFactory task.name.grouper.factory=org.apache.samza.container.grouper.task.GroupByContainerIdsFactory
# default system # Configure Kafka as "system"
job.default.system=kafka job.default.system=kafka
systems.kafka.samza.factory=org.apache.samza.system.kafka.KafkaSystemFactory systems.kafka.samza.factory=org.apache.samza.system.kafka.KafkaSystemFactory
systems.kafka.consumer.zookeeper.connect=zookeeper:2181 systems.kafka.consumer.bootstrap.servers=localhost:9092
#systems.kafka.consumer.zookeeper.connect=my-confluent-cp-zookeeper:2181 systems.kafka.producer.bootstrap.servers=localhost:9092
systems.kafka.producer.bootstrap.servers=kafka:9092
#systems.kafka.producer.bootstrap.servers=my-confluent-cp-kafka:9092
systems.kafka.default.stream.replication.factor=1 systems.kafka.default.stream.replication.factor=1
# Configure serialization and stores
serializers.registry.string.class=org.apache.samza.serializers.StringSerdeFactory serializers.registry.string.class=org.apache.samza.serializers.StringSerdeFactory
stores.my-store.factory=org.apache.samza.storage.kv.RocksDbKeyValueStorageEngineFactory stores.my-store.factory=org.apache.samza.storage.kv.RocksDbKeyValueStorageEngineFactory
stores.my-store.key.serde=string stores.my-store.key.serde=string
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment