SAMZA-730: added metrics serde for the metrics stream (was using json serde)
Project: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/commit/6c262408 Tree: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/tree/6c262408 Diff: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/diff/6c262408 Branch: refs/heads/latest Commit: 6c26240811b92a78460f02df0b4cc6d1c3fcade4 Parents: c1c153f Author: Steven Aerts <[email protected]> Authored: Mon Jul 13 14:58:09 2015 -0700 Committer: Yi Pan (Data Infrastructure) <[email protected]> Committed: Mon Dec 21 23:02:18 2015 -0800 ---------------------------------------------------------------------- src/main/config/wikipedia-parser.properties | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza-hello-samza/blob/6c262408/src/main/config/wikipedia-parser.properties ---------------------------------------------------------------------- diff --git a/src/main/config/wikipedia-parser.properties b/src/main/config/wikipedia-parser.properties index 8f1086f..6d1e3df 100644 --- a/src/main/config/wikipedia-parser.properties +++ b/src/main/config/wikipedia-parser.properties @@ -39,6 +39,7 @@ serializers.registry.metrics.class=org.apache.samza.serializers.MetricsSnapshotS # Systems systems.kafka.samza.factory=org.apache.samza.system.kafka.KafkaSystemFactory systems.kafka.samza.msg.serde=json +systems.kafka.streams.metrics.samza.msg.serde=metrics systems.kafka.consumer.zookeeper.connect=localhost:2181/ systems.kafka.consumer.auto.offset.reset=largest systems.kafka.producer.bootstrap.servers=localhost:9092
