Hello,
I have been able to execute my Samza-Beam application in Local mode. And now I
am trying to run a Samza-Beam application in Standalone mode.
Here is my configFile config.properties:
app.name=test-app
job.coordinator.factory=org.apache.samza.zk.ZkJobCoordinatorFactory
job.coordinator.zk.connect=localhost:2181
job.coordinator.system=kafka
job.factory.class=org.apache.samza.job.local.ProcessJobFactory
# Kafka System
systems.kafka.samza.factory=org.apache.samza.system.kafka.KafkaSystemFactory
systems.kafka.consumer.zookeeper.connect=localhost:2181
systems.kafka.producer.bootstrap.servers=localhost:9092
systems.kafka.default.stream.replication.factor=1
I am getting following exception:
org.apache.samza.config.ConfigException: Legacy task applications must set a
non-empty task.class in configuration.
at
org.apache.samza.application.ApplicationUtil.fromConfig(ApplicationUtil.java:58)
at
org.apache.samza.runtime.LocalContainerRunner.main(LocalContainerRunner.java:87)
Versions:
<beam.version>2.9.0</beam.version>
<samza.version>0.14.1</samza.version>
As per my understanding, I shouldn’t have to create implementation of
StreamApplication or StreamTask while using Beam SDK.
An example of configFile for Samza-Beam Standalone application would be helpful.
Regards,
Omkar Deshpande
