Repository: incubator-samza Updated Branches: refs/heads/0.7.0-local [created] d3de82b43
SAMZA-239: add information about how to create stream partitions Project: http://git-wip-us.apache.org/repos/asf/incubator-samza/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-samza/commit/d3de82b4 Tree: http://git-wip-us.apache.org/repos/asf/incubator-samza/tree/d3de82b4 Diff: http://git-wip-us.apache.org/repos/asf/incubator-samza/diff/d3de82b4 Branch: refs/heads/0.7.0-local Commit: d3de82b439299c1e75eee2a3fcb2135de4f32308 Parents: 9242f5d Author: Yan Fang <[email protected]> Authored: Tue Jun 17 23:19:50 2014 -0700 Committer: Yan Fang <[email protected]> Committed: Tue Jun 17 23:19:50 2014 -0700 ---------------------------------------------------------------------- docs/learn/documentation/0.7.0/container/samza-container.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-samza/blob/d3de82b4/docs/learn/documentation/0.7.0/container/samza-container.md ---------------------------------------------------------------------- diff --git a/docs/learn/documentation/0.7.0/container/samza-container.md b/docs/learn/documentation/0.7.0/container/samza-container.md index 141070f..cdcf8b6 100644 --- a/docs/learn/documentation/0.7.0/container/samza-container.md +++ b/docs/learn/documentation/0.7.0/container/samza-container.md @@ -47,7 +47,7 @@ How many instances of your task class are created depends on the number of parti <img src="/img/0.7.0/learn/documentation/container/tasks-and-partitions.svg" alt="Illustration of tasks consuming partitions" class="diagram-large"> -The number of partitions in the input streams is determined by the systems from which you are consuming. For example, if your input system is Kafka, you can specify the number of partitions when you create a topic. +The number of partitions in the input streams is determined by the systems from which you are consuming. For example, if your input system is Kafka, you can specify the number of partitions when you create a topic from the command line or using the num.partitions in Kafka's server properties file. If a Samza job has more than one input stream, the number of task instances for the Samza job is the maximum number of partitions across all input streams. For example, if a Samza job is reading from PageViewEvent (12 partitions), and ServiceMetricEvent (14 partitions), then the Samza job would have 14 task instances (numbered 0 through 13). Task instances 12 and 13 only receive events from ServiceMetricEvent, because there is no corresponding PageViewEvent partition.
