Typo

uber-archive · Apr 4, 2017 · fcf9846 · fcf9846
1 parent f71c67e
commit fcf9846
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/services/outputhost/kafkaAddresser.go b/services/outputhost/kafkaAddresser.go
@@ -115,7 +115,7 @@ func (k *kafkaTopicPartitionAddresser) GetStoreAddress(tp *topicPartition, offse
 		`topic`:     tp.Topic,
 		`partition`: tp.Partition,
 		`offset`:    offset,
-		`tpInt`:     k.nextTp,
+		`tpInt`:     k.nextTP,
 	}).Info(`New assignment`)
 
 	return calc(k.nextTP, offset)