No need for promise

twmb · Sep 1, 2022 · 1a1a517 · 1a1a517
1 parent 11f9f49
commit 1a1a517
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git 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
@@ -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)
 		}
 	}