Write a delivery mechanism for the in-memory channel implementation. This should include:
- Deployment to run the channel
- Ability to receive events on a Service (k8s Service preferred, Istio service optionally) and enqueue them to a Kafka Topic (unsharded is fine for now)
- Ability to read events via a kafka subscription offset per Subscriber and deliver to a destination (provided by the controller, possibly via ConfigMap)
- Integrate with delivery sidecar for call/to behavior.
- RBAC roles for any access needed by 1.
Write a delivery mechanism for the in-memory channel implementation. This should include: