Hi All, I was referring the hello-samza project as was able to run it successfully. I was able to run all the jobs and also wrote a consumer task to listen to kafka.wikipedia-stats topic.
I now want to write a Samza job that act as a KafkaProducer to continuously publishes simple string messages to a topic. Just like the WikipediaFeedStreamTask that reads Wikipedia events and publishes them to a topic. I am not sure of the any value of task.inputs in the config properties file? The way I think is like a java program publishing string messages to a kafka topic. How can I write such a Samza job? Any pointers would be of great help. Later on I want can read the same messages from a consumer like WikipediaParserStreamTask does. Referring the hello-samza project I was able to write a Consumer task that reads messages from the topic(kafka.wikipedia-stats) by simply task.class=samza.examples.wikipedia.task.TestConsumer task.inputs=kafka.wikipedia-stats Thanks, -Nirmal ________________________________ NOTE: This message may contain information that is confidential, proprietary, privileged or otherwise protected by law. The message is intended solely for the named addressee. If received in error, please destroy and notify the sender. Any use of this email is prohibited when received in error. Impetus does not represent, warrant and/or guarantee, that the integrity of this communication has been maintained nor that the communication is free of errors, virus, interception or interference.
