apache · thunguo · Jul 10, 2026 · Jun 13, 2026 · Jun 14, 2026 · Jun 14, 2026
diff --git a/pkg/integration/rocketmq/config.go b/pkg/integration/rocketmq/config.go
@@ -31,12 +31,14 @@ type SeataMQProducerConfig struct {
 
 	RetryTimesWhenSendFailed int
 	SendMsgTimeout           time.Duration
+	ConnPoolSize             int
 }
 
 func NewDefaultSeataMQProducerConfig() *SeataMQProducerConfig {
 	return &SeataMQProducerConfig{
 		RetryTimesWhenSendFailed: 3,
 		SendMsgTimeout:           3 * time.Second,
+		ConnPoolSize:             4,
 	}
 }
 

diff --git a/pkg/integration/rocketmq/constants.go b/pkg/integration/rocketmq/constants.go
@@ -26,4 +26,5 @@ const (
 	ActionContextKeyQueueOffset   = "queueOffset"
 	ActionContextKeyTransactionId = "transactionId"
 	ActionContextKeyBrokerName    = "brokerName"
+	ActionContextKeyTopic         = "topic"
 )