Implement Kafka middleware.

With CloudEvents: similar to https://github.com/knative-extensions/func-go/blob/main/cmd/fce/main.go
With raw messages: similar to https://github.com/knative-extensions/func-go/blob/main/cmd/fhttp/main.go