Eventhub scalar fix
* Event Hub scalar expansion to work with Java and C# applications
Made changes to event hub scalar codes
* Fixed variable declaration and value assignment bug for Event Hub Scalar
* Removed trailing spaces from blob store endpoint suffix for event hub scalar
@@ -80,6 +80,9 @@ func GetCheckpointFromBlobStorage(ctx context.Context, partitionID string, event
return Checkpoint{}, fmt.Errorf("unable to parse storage connection string: %s", err)
}
+ // Remove trailing spaces from endpointSuffix
+ endpointSuffix = strings.TrimSpace(endpointSuffix)
+
eventHubNamespace, eventHubName, err := ParseAzureEventHubConnectionString(eventHubMetadata.eventHubConnection)
if err != nil {
return Checkpoint{}, fmt.Errorf("unable to parse event hub connection string: %s", err)
