diff --git a/services/outputhost/kafkaAddresser.go b/services/outputhost/kafkaAddresser.go
index cc8e5974..c72faf77 100644
--- 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)