Skip to content

Commit b98a013

Browse files
authored
Merge pull request #108379 from ObrebskiAdam/patch-2
Change eventhub checkpoint to support NewBlobStore
2 parents 137c1f9 + 99a0b84 commit b98a013

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

articles/event-hubs/event-hubs-go-get-started-send.md

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -142,8 +142,11 @@ import (
142142

143143
func main() {
144144

145+
// create a container client using a connection string and container name
146+
checkClient, err := container.NewClientFromConnectionString("AZURE STORAGE CONNECTION STRING", "CONTAINER NAME", nil)
147+
145148
// create a checkpoint store that will be used by the event hub
146-
checkpointStore, err := checkpoints.NewBlobStoreFromConnectionString("AZURE STORAGE CONNECTION STRING", "BLOB CONTAINER NAME", nil)
149+
checkpointStore, err := checkpoints.NewBlobStore(checkClient, nil)
147150

148151
if err != nil {
149152
panic(err)

0 commit comments

Comments
 (0)