The example for configuring a stream by partition uses:
Example: task.broadcast.inputs=mySystem.broadcastStream#[1-2], mySystem.broadcastStream#1
Kafka partitions start with index 0. It's very confusing to have both examples start at index 1. This threw me for a bit before I realized that the example was misleading. Not handling partition 0 caused my tasks to crash at startup.