Skip to content

hbouvier/function-simple-kafka-consumer

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

14 Commits
 
 
 
 
 
 
 
 
 
 

Repository files navigation

Simple kafka function

To use libraries in the function

go get -u github.com/golang/dep/cmd/dep
cd ~/gopath/src/github.com/hbouvier/function-simple-kafka-consume
cd kafka-message
dep init .
# dep ensure -add github.com/google/uuid
# dep ensure -add github.com/segmentio/kafka-go
cd ..
faas-cli build

To create the sealed secrets

~/bin/kubeseal --fetch-cert --controller-name ofc-sealedsecrets-sealed-secrets  > pub-cert.pem
faas-cli cloud seal --name hbouvier-function-simple-kafka-consumer --literal kafka-response-topic=response --literal kafka-url=kafka.openfaas:9092

About

A simple kafka consumer in go implemented as an OpenFaaS function

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages