We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
hub initialized with connectionString and filePersister
ctx := context.Background() fp, err := persist.NewFilePersister(persistDir) if err != nil { fmt.Println(err.Error()) os.Exit(1) } hub, err := eventhub.NewHubFromConnectionString(connStr, eventhub.HubWithOffsetPersistence(output)) if err != nil { fmt.Println(err.Error()) os.Exit(1) } defer hub.Close(ctx) runtimeInfo, err := hub.GetRuntimeInformation(ctx) if err != nil { fmt.Println(err.Error()) os.Exit(1) } partitionIds := runtimeInfo.PartitionIDs consumerGroup := os.Getenv("EVENTHUB_CONSUMERGROUP") if consumerGroup == "" { consumerGroup = "$Default" } for _, partitionId := range partitionIds { _, err = hub.Receive(ctx, partitionId, output.HandleEvent, eventhub.ReceiveWithConsumerGroup(consumerGroup), eventhub.ReceiveWithPrefetchCount(20000)) if err != nil { fmt.Println(err.Error()) os.Exit(1) } }
should be able to create new file instead of throwing error
when file doesn't exist, it returns NewCheckpointFromStartOfStream(), err but err is not nil, and caused receive to fail here
NewCheckpointFromStartOfStream(), err
The text was updated successfully, but these errors were encountered:
@smartpcr Did you find a solution to this issue? Or how did you go about creating the file if it doesn't exist?
Sorry, something went wrong.
No branches or pull requests
hub initialized with connectionString and filePersister
Expected Behavior
should be able to create new file instead of throwing error
Actual Behavior
when file doesn't exist, it returns
NewCheckpointFromStartOfStream(), err
but err is not nil, and caused receive to fail hereEnvironment
The text was updated successfully, but these errors were encountered: