-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/26695/
-----------------------------------------------------------
(Updated Oct. 15, 2014, 4:49 p.m.)
Review request for samza.
Changes
-------
1. updated createTopicIfNotExist in KafkaUtil. Make it accept topic config
2. added docs
Bugs: SAMZA-310
https://issues.apache.org/jira/browse/SAMZA-310
Repository: samza
Description
-------
Publish the logs to the Kafka topic
Diffs (updated)
-----
docs/learn/documentation/versioned/jobs/logging.md 6739740
samza-api/src/main/java/org/apache/samza/job/CommandBuilder.java f510ce5
samza-core/src/main/scala/org/apache/samza/config/ShellCommandConfig.scala
69cea2c
samza-core/src/main/scala/org/apache/samza/job/ShellCommandBuilder.scala
7519117
samza-kafka/src/main/scala/org/apache/samza/util/KafkaLog4jAppender.scala
PRE-CREATION
samza-kafka/src/main/scala/org/apache/samza/util/KafkaUtil.scala d660b91
samza-kafka/src/main/scala/org/apache/samza/util/TaskIdPartitioner.scala
PRE-CREATION
samza-kafka/src/test/scala/org/apache/samza/util/TestKafkaLog4jAppender.scala
PRE-CREATION
samza-kafka/src/test/scala/org/apache/samza/util/TestKafkaUtil.scala
PRE-CREATION
samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaAppMasterTaskManager.scala
5b6cc81
Diff: https://reviews.apache.org/r/26695/diff/
Testing
-------
Thanks,
Yan Fang
