diff --git a/pkg/kgo/hooks.go b/pkg/kgo/hooks.go
index 7f7a7073..5f4efc53 100644
--- a/pkg/kgo/hooks.go
+++ b/pkg/kgo/hooks.go
@@ -195,7 +195,7 @@ type HookGroupManageError interface {
 //////////
 
 type HookProduce interface {
-	OnProduce(ctx context.Context, r *Record, promise func(*Record, error))
+	OnProduce(ctx context.Context, r *Record)
 }
 
 ///////////////////////////////
diff --git a/pkg/kgo/producer.go b/pkg/kgo/producer.go
index f6bb8965..7402813c 100644
--- a/pkg/kgo/producer.go
+++ b/pkg/kgo/producer.go
@@ -378,7 +378,7 @@ func (cl *Client) produce(
 	p := &cl.producer
 	if p.hooks != nil {
 		for _, h := range p.hooks.onProduce {
-			h.OnProduce(ctx, r, promise)
+			h.OnProduce(ctx, r)
 		}
 	}