I am prototyping an application where I have two input topics and two output topics. The application also uses a rocksdb state store that is backed by kafka.
I followed WikipediaZkLocalApplication example, but the application always exits without listening for messages from topic. I could see the execution plan and job coordinator communicating with zookeeper. I could see the following line in logs StreamProcessor [INFO] Container is not instantiated for stream processor: 5f7e2a46-fb7a-4054-bf5c-c62423ca2e35. I could not figure out why the container wouldn't start. Any help would be appreciated. Attached is the log and the job configuration. -anoop
job.name=iva-stream-application job.default.system=kafka job.coordinator.factory=org.apache.samza.zk.ZkJobCoordinatorFactory job.coordinator.zk.connect=localhost:2181 # 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.producer.max.request.size=15000180 systems.kafka.default.stream.replication.factor=1 # Input Streams streams.sensor-audit.samza.system=kafka streams.sensor-audit.samza.physical.name=rsdata.public.issues streams.risk-updates.samza.system=kafka streams.risk-updates.samza.physical.name=rsdata.public.rs_updates_issues_timestamps2 # State store serializers.registry.string.class=org.apache.samza.serializers.StringSerdeFactory serializers.registry.assetlabelserde.class=com.rootsecure.insights.serde.AssetLabelSerdeFactory stores.AssetLabelStore.factory=org.apache.samza.storage.kv.RocksDbKeyValueStorageEngineFactory stores.AssetLabelStore.changelog=kafka.asset-labels-changelog stores.AssetLabelStore.key.serde=string stores.AssetLabelStore.msg.serde=assetlabelserde
