Hi,
Trying a first app on Samza and used the hello-samza as model. When I
run the app, get the following:
2015-12-28 14:17:14 SamzaContainer$ [INFO] Got system factories: Set(product,
kafka)
2015-12-28 14:17:14 SamzaContainer$ [INFO] Got input stream metadata:
Map(SystemStream [system=product, stream=product.txt] -> SystemStreamMetadata
[streamName=product.txt, partitionMetadata={Partition
[partition=0]=SystemStreamPartitionMetadata [oldestOffset=null,
newestOffset=null, upcomingOffset=null]}])
2015-12-28 14:17:14 SamzaContainer$ [INFO] Failed to create a consumer for
product, so skipping.
2015-12-28 14:17:14 SamzaContainer$ [INFO] Got system consumers: Set()
2015-12-28 14:17:14 SamzaContainer$ [INFO] Failed to create a producer for
product, so skipping.
What am I missing ?
My config...
# Job
job.factory.class=org.apache.samza.job.yarn.YarnJobFactory
job.name=file-feed
# YARN
yarn.package.path=file://${basedir}/target/${project.artifactId}-${pom.version}-dist.tar.gz
# Task
task.class=com.test.samza.task.FileFeedStreamTask
task.inputs=product.product.txt
# Serializers
serializers.registry.json.class=org.apache.samza.serializers.JsonSerdeFactory
serializers.registry.string.class=org.apache.samza.serializers.StringSerdeFactory
# FileFeed System - product
systems.product.samza.factory=com.test.samza.system.FileFeedSystemFactory
# Kafka System
systems.kafka.samza.factory=org.apache.samza.system.kafka.KafkaSystemFactory
systems.kafka.samza.msg.serde=json
systems.kafka.consumer.zookeeper.connect=localhost:2181/
systems.kafka.producer.bootstrap.servers=localhost:9092
# Job Coordinator
job.coordinator.system=kafka
# Add configuration to disable checkpointing for this job once it is available
in the Coordinator Stream model
# See
https://issues.apache.org/jira/browse/SAMZA-465?focusedCommentId=14533346&page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#comment-14533346
for more details
job.coordinator.replication.factor=1
Thanks and Regards,
marcelo
