Function ForwardToKafka

functions/knative/with-output-binding/sender.go:10–27

(ctx ofctx.Context, in []byte)

)

func ForwardToKafka(ctx ofctx.Context, in []byte) (ofctx.Out, error) {
	var greeting []byte
	if in != nil {
		log.Printf("http - Data: %s", in)
		greeting = in
	} else {
		log.Print("http - Data: Received")
		greeting, _ = json.Marshal(map[string]string{"message": "Hello"})
	}

	_, err := ctx.Send("kafka-server", greeting)
	if err != nil {
		log.Print(err.Error())
		return ctx.ReturnOnInternalError(), err
	}

	return ctx.ReturnOnSuccess(), nil
}