kafka.go package middleware import ( "context" "encoding/base64" "encoding/json" "errors" "fmt" "os" "strconv" "strings" "github.com/Shopify/sarama" "github.com/garyburd/redig…