From a97eb7b7c9f9bbe6c87a46cb7632ae0acdb6b1b5 Mon Sep 17 00:00:00 2001
From: Gordon <1432970085@qq.com>
Date: Wed, 8 Jun 2022 17:17:55 +0800
Subject: [PATCH] log

---
 pkg/common/kafka/producer.go | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/pkg/common/kafka/producer.go b/pkg/common/kafka/producer.go
index 98ad92209..fb922c5c0 100644
--- a/pkg/common/kafka/producer.go
+++ b/pkg/common/kafka/producer.go
@@ -2,6 +2,7 @@ package kafka
 
 import (
 	log2 "Open_IM/pkg/common/log"
+	"errors"
 	"github.com/Shopify/sarama"
 	"github.com/golang/protobuf/proto"
 )
@@ -43,6 +44,9 @@ func (p *Producer) SendMessage(m proto.Message, key ...string) (int32, int64, er
 		log2.Error("", "", "proto marshal err = %s", err.Error())
 		return -1, -1, err
 	}
+	if len(bMsg) == 0 {
+		return 0, 0, errors.New("msg content is nil")
+	}
 	kMsg.Value = sarama.ByteEncoder(bMsg)
 
 	return p.producer.SendMessage(kMsg)