diff --git a/outlet/kafka/root.go b/outlet/kafka/root.go
index 2bfbf94f..b968023c 100644
--- a/outlet/kafka/root.go
+++ b/outlet/kafka/root.go
@@ -135,7 +135,7 @@ func (c *realComponent) Start() error {
 
 // StartWorkers will start the initial workers. This should only be called once.
 func (c *realComponent) StartWorkers(workerBuilder WorkerBuilderFunc) error {
-	c.workerRequestChan = c.startScaler()
+	c.workerRequestChan = c.runScaler()
 	c.workerBuilder = workerBuilder
 	for range c.config.MinWorkers {
 		if err := c.startOneWorker(); err != nil {
diff --git a/outlet/kafka/scaler.go b/outlet/kafka/scaler.go
index 7c531031..f96175ec 100644
--- a/outlet/kafka/scaler.go
+++ b/outlet/kafka/scaler.go
@@ -76,8 +76,8 @@ func (s *scalerState) nextWorkerCount(request ScaleRequest, minWorkers, maxWorke
 	return next
 }
 
-// startScaler starts the automatic scaling loop
-func (c *realComponent) startScaler() chan<- ScaleRequest {
+// runScaler starts the automatic scaling loop
+func (c *realComponent) runScaler() chan<- ScaleRequest {
 	ch := make(chan ScaleRequest, c.config.MaxWorkers)
 	down := rate.Sometimes{Interval: c.config.WorkerDecreaseRateLimit}
 	up := rate.Sometimes{Interval: c.config.WorkerIncreaseRateLimit}