diff --git a/examples/producer/transaction/main.go b/examples/producer/transaction/main.go
index 919c6a5c..d56e9c8f 100644
--- a/examples/producer/transaction/main.go
+++ b/examples/producer/transaction/main.go
@@ -49,7 +49,7 @@ func (dl *DemoListener) ExecuteLocalTransaction(msg *primitive.Message) primitiv
 	dl.localTrans.Store(msg.TransactionId, primitive.LocalTransactionState(status+1))
 
 	fmt.Printf("dl")
-	return primitive.UnkonwnState
+	return primitive.UnknownState
 }
 
 func (dl *DemoListener) CheckLocalTransaction(msg *primitive.MessageExt) primitive.LocalTransactionState {
@@ -69,7 +69,7 @@ func (dl *DemoListener) CheckLocalTransaction(msg *primitive.MessageExt) primiti
 		return primitive.RollbackMessageState
 	case 3:
 		fmt.Printf("checkLocalTransaction unknown: %v\n", msg)
-		return primitive.UnkonwnState
+		return primitive.UnknownState
 	default:
 		fmt.Printf("checkLocalTransaction default COMMIT_MESSAGE: %v\n", msg)
 		return primitive.CommitMessageState
diff --git a/primitive/message.go b/primitive/message.go
index 8b390c49..8217595c 100644
--- a/primitive/message.go
+++ b/primitive/message.go
@@ -451,7 +451,7 @@ type LocalTransactionState int
 const (
 	CommitMessageState LocalTransactionState = iota + 1
 	RollbackMessageState
-	UnkonwnState
+	UnknownState
 )
 
 type TransactionListener interface {
diff --git a/producer/producer.go b/producer/producer.go
index 00eb351d..2c076a17 100644
--- a/producer/producer.go
+++ b/producer/producer.go
@@ -714,7 +714,7 @@ func (tp *transactionProducer) SendMessageInTransaction(ctx context.Context, msg
 	if err != nil {
 		return nil, err
 	}
-	localTransactionState := primitive.UnkonwnState
+	localTransactionState := primitive.UnknownState
 	switch rsp.Status {
 	case primitive.SendOK:
 		if len(rsp.TransactionID) > 0 {
@@ -785,7 +785,7 @@ func (tp *transactionProducer) transactionState(state primitive.LocalTransaction
 		return primitive.TransactionCommitType
 	case primitive.RollbackMessageState:
 		return primitive.TransactionRollbackType
-	case primitive.UnkonwnState:
+	case primitive.UnknownState:
 		return primitive.TransactionNotType
 	default:
 		return primitive.TransactionNotType