From c69d35789d5d6938f3e1e87472395508531e2f3f Mon Sep 17 00:00:00 2001 From: lorenz <stu203404@mail.uni-kiel.de> Date: Fri, 24 Dec 2021 13:08:51 +0100 Subject: [PATCH] Add forgotten serializing options to beam samza --- .../uc4-beam-samza/samza-standalone.properties | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/theodolite-benchmarks/uc4-beam-samza/samza-standalone.properties b/theodolite-benchmarks/uc4-beam-samza/samza-standalone.properties index 8044fe3d7..6f1f1aa65 100644 --- a/theodolite-benchmarks/uc4-beam-samza/samza-standalone.properties +++ b/theodolite-benchmarks/uc4-beam-samza/samza-standalone.properties @@ -15,3 +15,9 @@ systems.kafka.consumer.zookeeper.connect=zookeeper:2181 systems.kafka.producer.bootstrap.servers=kafka:9092 #systems.kafka.producer.bootstrap.servers=my-confluent-cp-kafka:9092 systems.kafka.default.stream.replication.factor=1 + + +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 +stores.my-store.msg.serde=string -- GitLab