Hi everyone, As the subject said, I want to read from external source (simplest case is to read from a file) and write to a Kafka stream. Then another StreamTask will start reading from the Kafka stream.
I've succeeded running HelloSamza, write a similar app (VERY similar) that have a custom Consumer reading from a file then write to a custom system (i.e.: testsystem.mystream). Then I have a StreamTask that read from this custom stream, and write to a kafka stream. However, I want to bypass the custom stream and write the message from the external source directly to the Kafka stream. I guess I will have to implement the SystemFactory such that it will return a Kafka producer for the getProducer() method but I'm not very sure how to yet. Although I basically welcome & appreciate very much all guides/advises/suggestions, my main objective of this mail is to ask for the link to the thread "Writing a simple KafkaProducer in Samza" that was mentioned in https://mail-archives.apache.org/mod_mbox/incubator-samza-dev/201311.mbox/%3CEA1B8C30F3B4C34EBA71F2AAF48F5990D612E028%40Mail3.impetus.co.in%3E Thank you very much, Casey
