summaryrefslogtreecommitdiff
path: root/producer.go
diff options
context:
space:
mode:
Diffstat (limited to 'producer.go')
-rw-r--r--producer.go9
1 files changed, 6 insertions, 3 deletions
diff --git a/producer.go b/producer.go
index 8cf1b0e..f5392ae 100644
--- a/producer.go
+++ b/producer.go
@@ -2,11 +2,11 @@ package main
import (
"fmt"
+ "github.com/confluentinc/confluent-kafka-go/v2/kafka"
"kafka-sandbox/util"
+ "log"
"math/rand"
"os"
-
- "github.com/confluentinc/confluent-kafka-go/kafka"
)
func main() {
@@ -49,11 +49,14 @@ func main() {
for n := 0; n < 10; n++ {
key := users[rand.Intn(len(users))]
data := items[rand.Intn(len(items))]
- p.Produce(&kafka.Message{
+ err := p.Produce(&kafka.Message{
TopicPartition: kafka.TopicPartition{Topic: &topic, Partition: kafka.PartitionAny},
Key: []byte(key),
Value: []byte(data),
}, nil)
+ if err != nil {
+ log.Fatalln(err)
+ }
}
// Wait for all messages to be delivered