diff --git a/sysmodule/kafkamodule/Consumer.go b/sysmodule/kafkamodule/Consumer.go
index ec448fc..52f27e2 100644
--- a/sysmodule/kafkamodule/Consumer.go
+++ b/sysmodule/kafkamodule/Consumer.go
@@ -248,7 +248,7 @@ func (ch *ConsumerGroupHandler) ConsumeClaim(session sarama.ConsumerGroupSession
 		select {
 		case msg := <-claim.Messages():
 			if msg == nil {
-				log.SWarning("claim will exit", log.Any("topic", claim.Topic()), log.Any("Partition", claim.Partition()))
+				log.SWarn("claim will exit", log.Any("topic", claim.Topic()), log.Any("Partition", claim.Partition()))
 				return nil
 			}
 			ch.AppendMsg(session, msg)
diff --git a/sysmodule/kafkamodule/Producer.go b/sysmodule/kafkamodule/Producer.go
index a5409d4..727181c 100644
--- a/sysmodule/kafkamodule/Producer.go
+++ b/sysmodule/kafkamodule/Producer.go
@@ -86,7 +86,7 @@ func (p *Producer) asyncRun() {
 			asyncReturn := sm.Metadata.(*AsyncReturn)
 			asyncReturn.chanReturn <- asyncReturn
 		case em := <-p.Errors():
-			log.Error("async kafkamodule error", log.ErrorAttr("err", em.Err))
+			log.Error("async kafkamodule error", log.ErrorField("err", em.Err))
 			if em.Msg.Metadata == nil {
 				break
 			}