We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 421346a commit f6d1602Copy full SHA for f6d1602
pkg/v3ctl/stream/createrecord.go
@@ -60,6 +60,12 @@ func newCreateRecordCommandeer(createStreamCommandeer *createStreamCommandeer) (
60
return errors.Wrap(err, "Failed to get create stream")
61
}
62
63
+ putRecordsResponse, ok := response.Output.(v3io.PutRecordsOutput)
64
+ if ok && putRecordsResponse.FailedRecordCount != 0 {
65
+ return errors.Errorf("Failed to put all records, FailedRecordCount: %d",
66
+ putRecordsResponse.FailedRecordCount)
67
+ }
68
+
69
defer response.Release()
70
71
fmt.Printf("Wrote %d bytes to %s:%d\n",
0 commit comments