minor changes

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-09-23 08:03:14 +03:00
parent e43584ed6d
commit be1c68e6a5
1 changed files with 1 additions and 1 deletions
--- a/util.go
+++ b/util.go
@@ -15,7 +15,7 @@ var ErrLostMessage = errors.New("message not marked for offsets commit and will

 var pPool = sync.Pool{
 	New: func() interface{} {
-		return &publication{msg: &broker.Message{}}
+		return &publication{msg: broker.NewMessage("")}
 	},
 }