Hi, I’m creating an application that is supposed to do the following: Create messages at a fixed frequency of messages per second. I don’t have it in files or anything, the idea is to create the messages in samza and send it downstream to be processed.
I have looked into some examples and looks like the way to do this is to create a SystemConsumer that produces this messages and sends it to a Kafka topic. Does this sounds right? Can anyone give me a hint on how to start this implementation, I studied hello-samza job but I couldn’t figure it out how to do it properly. Thanks in advance.
