Hi group
I'm doing some research on samza. Currently I am playing with hello-samza
and try to write simple project based on it.
I've noticed that the metrics are never written to kafka. After reading
around samza doc, I think this config is missed in
the wikipedia-parser.properties:
systems.kafka.streams.metrics.samza.msg.serde=metrics
ref: http://samza.apache.org/learn/documentation/0.9/container/metrics.html
Metrics are written to kafka correctly after adding this to the metrics
config.
Hope it's correct for 0.10.
--
All the best
Liu Bo