diff --git a/faust/assignor/partition_assignor.py b/faust/assignor/partition_assignor.py index 78c15c4f9..be19074f4 100644 --- a/faust/assignor/partition_assignor.py +++ b/faust/assignor/partition_assignor.py @@ -329,6 +329,9 @@ def _global_table_standby_assignments( # Only add those partitions as standby which aren't active standby_partitions = all_partitions - active_partitions assignment.standbys[changelog_topic_name] = list(standby_partitions) + # We add all_partitions as active so they are recovered + # in the beginning. + assignment.actives[changelog_topic_name] = list(all_partitions) return assignments def _protocol_assignments(