Greetings all,
I am trying to translate an existing workflow from MR into Samza. Thus far everything is coded and kinks with deploying have been worked out. My task deploys into yarn (2.6.0), consumes records from Kafka (0.8.2.1) fine, but no data from metrics and my output streams are showing up in Kafka. I see the metrics topic created in Kafka, but its empty (I have a counter counting records seen). I have debug prints showing me that I am calling collector.send() which is also wrapped in a catch for Throwable. Nothing at all shows in the logs. I do see the checkpoint topic being used, and incremented appropriately. So between that and consuming records in the first place I think the system.kafka is configured correctly. I ran into serde issues with consumption and sending and fixed those too. Has anyone run into this kind of behavior? Am hoping its a dumb config issue. V/R, ~Garrett
