SAMZA-538; update hello-samza to use bootstrap.servers config
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/ea0db557 Tree: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/tree/ea0db557 Diff: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/diff/ea0db557 Branch: refs/heads/latest Commit: ea0db557533bb3cd84027d77cc0833134f9d72d8 Parents: 485aed3 Author: Chris Riccomini <[email protected]> Authored: Wed Feb 4 08:49:01 2015 -0800 Committer: Chris Riccomini <[email protected]> Committed: Wed Feb 4 08:49:01 2015 -0800 ---------------------------------------------------------------------- src/main/config/wikipedia-feed.properties | 5 +---- src/main/config/wikipedia-parser.properties | 6 +----- src/main/config/wikipedia-stats.properties | 8 ++++---- 3 files changed, 6 insertions(+), 13 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza-hello-samza/blob/ea0db557/src/main/config/wikipedia-feed.properties ---------------------------------------------------------------------- diff --git a/src/main/config/wikipedia-feed.properties b/src/main/config/wikipedia-feed.properties index c498c16..ce97357 100644 --- a/src/main/config/wikipedia-feed.properties +++ b/src/main/config/wikipedia-feed.properties @@ -38,7 +38,4 @@ systems.wikipedia.port=6667 systems.kafka.samza.factory=org.apache.samza.system.kafka.KafkaSystemFactory systems.kafka.samza.msg.serde=json systems.kafka.consumer.zookeeper.connect=localhost:2181/ -systems.kafka.producer.metadata.broker.list=localhost:9092 -systems.kafka.producer.producer.type=sync -# Normally, we'd set this much higher, but we want things to look snappy in the demo. -systems.kafka.producer.batch.num.messages=1 +systems.kafka.producer.bootstrap.servers=localhost:9092 http://git-wip-us.apache.org/repos/asf/samza-hello-samza/blob/ea0db557/src/main/config/wikipedia-parser.properties ---------------------------------------------------------------------- diff --git a/src/main/config/wikipedia-parser.properties b/src/main/config/wikipedia-parser.properties index 38575b6..e2742a5 100644 --- a/src/main/config/wikipedia-parser.properties +++ b/src/main/config/wikipedia-parser.properties @@ -45,8 +45,4 @@ systems.kafka.samza.factory=org.apache.samza.system.kafka.KafkaSystemFactory systems.kafka.samza.msg.serde=json systems.kafka.consumer.zookeeper.connect=localhost:2181/ systems.kafka.consumer.auto.offset.reset=largest -systems.kafka.producer.metadata.broker.list=localhost:9092 -systems.kafka.producer.producer.type=sync -# Normally, we'd set this much higher, but we want things to look snappy in the demo. -systems.kafka.producer.batch.num.messages=1 -systems.kafka.streams.metrics.samza.msg.serde=metrics +systems.kafka.producer.bootstrap.servers=localhost:9092 http://git-wip-us.apache.org/repos/asf/samza-hello-samza/blob/ea0db557/src/main/config/wikipedia-stats.properties ---------------------------------------------------------------------- diff --git a/src/main/config/wikipedia-stats.properties b/src/main/config/wikipedia-stats.properties index 69eff90..1ff3552 100644 --- a/src/main/config/wikipedia-stats.properties +++ b/src/main/config/wikipedia-stats.properties @@ -41,10 +41,7 @@ systems.kafka.samza.factory=org.apache.samza.system.kafka.KafkaSystemFactory systems.kafka.samza.msg.serde=json systems.kafka.consumer.zookeeper.connect=localhost:2181/ systems.kafka.consumer.auto.offset.reset=largest -systems.kafka.producer.metadata.broker.list=localhost:9092 -systems.kafka.producer.producer.type=sync -# Normally, we'd set this much higher, but we want things to look snappy in the demo. -systems.kafka.producer.batch.num.messages=1 +systems.kafka.producer.bootstrap.servers=localhost:9092 # Key-value storage stores.wikipedia-stats.factory=org.apache.samza.storage.kv.RocksDbKeyValueStorageEngineFactory @@ -52,6 +49,9 @@ stores.wikipedia-stats.changelog=kafka.wikipedia-stats-changelog stores.wikipedia-stats.key.serde=string stores.wikipedia-stats.msg.serde=integer +# Normally, we'd leave this alone, but we have only one broker. +stores.wikipedia-stats.changelog.replication.factor=1 + # Normally, we'd set this much higher, but we want things to look snappy in the demo. stores.wikipedia-stats.write.batch.size=0 stores.wikipedia-stats.object.cache.size=0
