chore: mark optional

unknowntpo · Sep 25, 2023 · 4813a8d · 4813a8d
1 parent 036ce13
commit 4813a8d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/cmd/agent.go b/cmd/agent.go
@@ -237,7 +237,7 @@ func (a *Agent) pg2pulsar(params *structpb.Struct) (*pb.AgentConfigResponse, err
 }
 
 func (a *Agent) pulsar2pg(params *structpb.Struct) (*pb.AgentConfigResponse, error) {
-	v, err := extract(params, "PGConnURL", "PulsarURL", "PulsarTopic", "BatchTxSize")
+	v, err := extract(params, "PGConnURL", "PulsarURL", "PulsarTopic", "?BatchTxSize")
 	if err != nil {
 		return nil, err
 	}