feature: consumer code

Makefile

@@ -1,15 +1,18 @@
-.PHONY: build
+.PHONY: build-producer build-consumer run dependencies infrastructure-local infrastructure-prod topic-scram topic-ssl consume-topic
 
 ACTION=apply
 
-build: dependencies
+build-producer: dependencies
-	go build -o out/kafka ./cmd/main.go
+	go build -o out/kafka-producer ./cmd/producer.go
+
+build-consumer: dependencies
+	go built -o out/kafka-consumer ./cmd/consumer.go
 
 dependencies:
 	go mod tidy
 
 run:
-	./out/kafka -c ./configuration.yaml
+	./out/kafka-producer -c ./configuration.yaml
 
 infrastructure-local:
 	cd manifest && \

cmd/producer.go

@@ -2,6 +2,7 @@ package main
 
 import (
 	. "antoine-roux.tk/kafka/internal/configuration"
+	"fmt"
 	"github.com/Shopify/sarama"
 	"log"
 	_ "net/http/pprof"
@@ -29,7 +30,7 @@ func main() {
 		_, _, err := producer.SendMessage(&sarama.ProducerMessage{
 			Topic: string(application.EmitterTopic),
 			Key:   nil,
-			Value: sarama.StringEncoder("test"),
+			Value: sarama.StringEncoder(fmt.Sprintf("test number %d", i)),
 		})
 		if err != nil {
 			log.Printf("Message delivery error %s\n", err)

configuration.template.yaml

@@ -13,7 +13,7 @@ kafka:
   # k view-secret -n streaming kafka-user user.key
   key: <client pem key>
 
-  # k view-secret kafka-dev-listener-certificate ca.crt
+  # k view-secret cluster-development-cluster-ca-cert ca.crt
   ca: <server root certificate>
   group-name: some-consumer-name
   topics: