diff --git a/broker.go b/broker.go
index b1207f2..2c9959b 100644
--- a/broker.go
+++ b/broker.go
@@ -49,8 +49,8 @@ func (b *broker) pollShards(ctx context.Context) {
 }
 
 // leaseShards attempts to find new shards that need to be
-// processed; when a new shard is found it passing the shard
-// ID back to the consumer on the shard channel
+// processed; when a new shard is found it passes the shard
+// ID back to the consumer on the shardc channel
 func (b *broker) leaseShards() {
 	b.shardMu.Lock()
 	defer b.shardMu.Unlock()