Leverage bigger batchsize when seeding example data

examples/producer/main.go

@@ -14,6 +14,8 @@ import (
 	"github.com/aws/aws-sdk-go/service/kinesis"
 )
 
+var svc = kinesis.New(session.New())
+
 func main() {
 	log.SetHandler(text.New(os.Stderr))
 	log.SetLevel(log.DebugLevel)
@@ -29,10 +31,7 @@ func main() {
 	}
 	defer f.Close()
 
-	var (
+	var records []*kinesis.PutRecordsRequestEntry
-		svc     = kinesis.New(session.New())
-		records []*kinesis.PutRecordsRequestEntry
-	)
 
 	// loop over file data
 	b := bufio.NewScanner(f)
@@ -42,17 +41,24 @@ func main() {
 			PartitionKey: aws.String(time.Now().Format(time.RFC3339Nano)),
 		})
 
-		if len(records) > 50 {
+		if len(records) > 250 {
-			_, err = svc.PutRecords(&kinesis.PutRecordsInput{
+			putRecords(streamName, records)
-				StreamName: streamName,
-				Records:    records,
-			})
-			if err != nil {
-				log.WithError(err).Fatal("error producing")
-			}
 			records = nil
 		}
+	}
 
-		fmt.Print(".")
+	if len(records) > 0 {
+		putRecords(streamName, records)
 	}
 }
+
+func putRecords(streamName *string, records []*kinesis.PutRecordsRequestEntry) {
+	_, err := svc.PutRecords(&kinesis.PutRecordsInput{
+		StreamName: streamName,
+		Records:    records,
+	})
+	if err != nil {
+		log.Fatal("error putting records")
+	}
+	fmt.Print(".")
+}