Skip to content

Commit

Permalink
Eventhub scalar fix (#537)
Browse files Browse the repository at this point in the history
* 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
  • Loading branch information
rasavant-ms authored and ahmelsayed committed Jan 13, 2020
1 parent b2b57f3 commit 19dd440
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions pkg/scalers/azure_eventhub.go
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down

0 comments on commit 19dd440

Please sign in to comment.