kafka-gateway

🎤 Kafka Gateway (gRPC+http) micro-service

A kafka gateway / proxy, developed as a micro-service using Sarama, Protobuf and Go-Kit, with more that 75% boilerplate code generated automatically using protoc-gen-gotemplate.

Usage

$> curl -X POST localhost:8000/Producer -d '{"topic":"test","value":{"test":42}}'
{"offset":14}
$> curl -X POST localhost:8000/Producer -d '{"topic":"test","value":{"test":42}}'
{"offset":15}

Code generation

# custom code
$> wc -l service/service.go pb/*.proto cmd/*/main.go
      47 service/service.go
      31 pb/kafka.proto
      85 cmd/kafkagw/main.go
     163 total

# generated code
$> wc -l $(find gen -name "*.go")
      73 gen/endpoints/endpoints.go
     263 gen/pb/kafka.pb.go
      90 gen/transports/grpc/grpc.go
      72 gen/transports/http/http.go
     498 total