introduction to the world

Author: nefro85

Dockerfile

@@ -0,0 +1,19 @@
+FROM golang:latest as stack
+
+RUN set -ex; \
+  mkdir /opt/kafka-gateway; \
+  go get -u gopkg.in/confluentinc/confluent-kafka-go.v1/kafka;
+
+FROM stack
+
+WORKDIR /opt/kafka-gateway
+COPY go.mod go.mod
+COPY go.sum go.sum
+COPY internal internal
+COPY cmd cmd
+COPY main.go main.go
+
+RUN set -ex; \
+  ls -ls; \
+  go version; \ 
+  go build -o ./bin/gateway;

README.md

@@ -0,0 +1,12 @@
+# Kafka Http Gateway
+
+
+
+
+### Dependenices
+
+[kafka]["github.com/confluentinc/confluent-kafka-go/kafka"]
+
+### Tips
+
+Setup the env `CGO_ENABLED=0` in order to build app with kafka lib.

dev.sh

@@ -0,0 +1,30 @@
+#!/bin/bash
+
+main () {
+
+    case $1 in
+        run)
+            dockerRun
+            ;;
+        build)
+            dockerBuild
+            ;;
+        *)
+        badOpt $@
+    esac
+
+}
+
+badOpt() {
+    echo bad options: $@
+}
+
+dockerRun() {
+    docker run --name kafka-gateway -it --rm s7i/kafka-gateway    
+}
+
+dockerBuild() {
+    docker build -t s7i/kafka-gateway .
+}
+
+main $@

go.mod

@@ -0,0 +1,5 @@
+module s7i.io/kafka-gateway
+
+go 1.17
+
+require github.com/confluentinc/confluent-kafka-go v1.7.0

go.sum

@@ -0,0 +1,2 @@
+github.com/confluentinc/confluent-kafka-go v1.7.0 h1:tXh3LWb2Ne0WiU3ng4h5qiGA9XV61rz46w60O+cq8bM=
+github.com/confluentinc/confluent-kafka-go v1.7.0/go.mod h1:u2zNLny2xq+5rWeTQjFHbDzzNuba4P1vo31r9r4uAdg=

internal/kafka/integration.go

@@ -0,0 +1,47 @@
+package kafka
+
+import (
+	"fmt"
+
+	"github.com/confluentinc/confluent-kafka-go/kafka"
+)
+
+type Properties struct {
+	Server string
+}
+
+type KafkaProducer struct {
+	prod *kafka.Producer
+}
+
+func (prod *KafkaProducer) Init(props *Properties) {
+	fmt.Println("making kafka producer")
+
+	p, err := kafka.NewProducer(&kafka.ConfigMap{"bootstrap.servers": props.Server})
+
+	if err != nil {
+
+		panic(err)
+	}
+	prod.prod = p
+
+	go func() {
+		for e := range p.Events() {
+			switch ev := e.(type) {
+			case *kafka.Message:
+				m := ev
+				if m.TopicPartition.Error != nil {
+					fmt.Printf("Delivery failed: %v\n", m.TopicPartition.Error)
+				} else {
+					fmt.Printf("Delivered message to topic %s [%d] at offset %v\n",
+						*m.TopicPartition.Topic, m.TopicPartition.Partition, m.TopicPartition.Offset)
+				}
+				return
+
+			default:
+				fmt.Printf("Ignored event: %s\n", ev)
+			}
+		}
+	}()
+
+}

main.go

@@ -0,0 +1,30 @@
+package main
+
+import (
+	"fmt"
+	"io"
+	"net/http"
+	"time"
+
+	"s7i.io/kafka-gateway/internal/kafka"
+)
+
+func main() {
+
+	prod := kafka.KafkaProducer{}
+	prod.Init(&kafka.Properties{Server: "localhost:9092"})
+
+	fmt.Println("running server")
+
+	http.HandleFunc("/hello", hndHello)
+	if err := http.ListenAndServe(":8080", nil); err != nil {
+		panic(err)
+	}
+
+}
+
+func hndHello(w http.ResponseWriter, req *http.Request) {
+	io.WriteString(w, "hello world @"+time.Now().String())
+
+	fmt.Println(req)
+}