fix: eh mirror params

PeerDB-io · Sep 12, 2023 · d767df0 · d767df0
1 parent e9bb5f2
commit d767df0
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/flow/connectors/eventhub/eventhub.go b/flow/connectors/eventhub/eventhub.go
@@ -116,7 +116,13 @@ func (c *EventHubConnector) SyncRecords(req *model.SyncRecordsRequest) (*model.S
 	batch := req.Records
 	eventsPerHeartBeat := 1000
 	eventsPerBatch := int(req.PushBatchSize)
+	if eventsPerBatch <= 0 {
+		eventsPerBatch = 10000
+	}
 	maxParallelism := req.PushParallelism
+	if maxParallelism <= 0 {
+		maxParallelism = 10
+	}
 
 	batchPerTopic := make(map[string][]*eventhub.Event)
 	for i, record := range batch.Records {