You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by xi...@apache.org on 2018/01/09 01:25:46 UTC

[05/33] samza-hello-samza git commit: SAMZA-730: added metrics serde for the metrics stream (was using json serde)

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/master
Commit: 6c26240811b92a78460f02df0b4cc6d1c3fcade4
Parents: c1c153f
Author: Steven Aerts <st...@gmail.com>
Authored: Mon Jul 13 14:58:09 2015 -0700
Committer: Yi Pan (Data Infrastructure) <ni...@gmail.com>
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