You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by ya...@apache.org on 2015/07/13 23:59:14 UTC
samza-hello-samza git commit: SAMZA-730: added metrics serde for the
metrics stream (was using json serde)
Repository: samza-hello-samza
Updated Branches:
refs/heads/master ff399e6d5 -> f88eb62d9
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/f88eb62d
Tree: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/tree/f88eb62d
Diff: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/diff/f88eb62d
Branch: refs/heads/master
Commit: f88eb62d97a7677b52894bb86de371f7e5b9266c
Parents: ff399e6
Author: Steven Aerts <st...@gmail.com>
Authored: Mon Jul 13 14:58:09 2015 -0700
Committer: Yan Fang <ya...@gmail.com>
Committed: Mon Jul 13 14:58:09 2015 -0700
----------------------------------------------------------------------
src/main/config/wikipedia-parser.properties | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/samza-hello-samza/blob/f88eb62d/src/main/config/wikipedia-parser.properties
----------------------------------------------------------------------
diff --git a/src/main/config/wikipedia-parser.properties b/src/main/config/wikipedia-parser.properties
index e2742a5..d80d59b 100644
--- a/src/main/config/wikipedia-parser.properties
+++ b/src/main/config/wikipedia-parser.properties
@@ -43,6 +43,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