add var for leader id

travisjeffery · Feb 13, 2017 · 2ce0047 · 2ce0047
1 parent fee05bf
commit 2ce0047
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/broker/broker.go b/broker/broker.go
@@ -284,11 +284,12 @@ func (b *Broker) CreateTopic(topic string, partitions int32) error {
 
 	for i := int32(0); i < partitions; i++ {
 		// TODO: need to know replica assignment here
+		leader := c[i%cLen].ID
 		partition := &jocko.Partition{
 			Topic:           topic,
 			ID:              i,
-			Leader:          c[i%cLen].ID,
-			PreferredLeader: c[i%cLen].ID,
+			Leader:          leader,
+			PreferredLeader: leader,
 			Replicas:        []int32{},
 		}
 		if err := b.AddPartition(partition); err != nil {