Repository: incubator-samza Updated Branches: refs/heads/master bad2deb4a -> 0705a0b69
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/0705a0b6 Tree: http://git-wip-us.apache.org/repos/asf/incubator-samza/tree/0705a0b6 Diff: http://git-wip-us.apache.org/repos/asf/incubator-samza/diff/0705a0b6 Branch: refs/heads/master Commit: 0705a0b690d1fcbd083c8877179cd68fb7ed7c0f Parents: bad2deb Author: Yan Fang <[email protected]> Authored: Tue Jun 17 23:27:18 2014 -0700 Committer: Yan Fang <[email protected]> Committed: Tue Jun 17 23:27:18 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/0705a0b6/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.
