diff --git a/processor.go b/processor.go
index f117025..238e817 100644
--- a/processor.go
+++ b/processor.go
@@ -4,7 +4,6 @@ import (
 	"context"
 	"errors"
 	"fmt"
-	"log/slog"
 	"sync"
 
 	"go.opentelemetry.io/otel"
@@ -24,7 +23,6 @@ type Processor[T1, T2 any] struct {
 	parallelism int
 	tracing     bool
 	metrics     bool
-	count       int
 }
 
 type Config[T1, T2 any] struct {
@@ -104,7 +102,6 @@ func (p *Processor[T1, T2]) handle(ctx context.Context) error {
 		if err != nil {
 			return fmt.Errorf("handler: %w", err)
 		}
-		p.count++
 		hdlSpan.End()
 
 		// If there are no messages, we don't need to send nil to destination
@@ -162,7 +159,6 @@ func (p *Processor[T1, T2]) Run(ctx context.Context) error {
 	}
 	// Stop all the workers on shutdown.
 	cancel()
-	slog.Info("shutting down processor", "count", p.count)
 	// TODO: capture errors thrown during shutdown?  if we do this, write local
 	// err first. it represents first seen
 	wg.Wait()