Add a kafka/ package implementing a Kafka middleware for Knative Functions, following the same patterns as the existing http/ and cloudevents/ packages.
- Sarama consumer group with at-least-once delivery, in-order per partition
- Raw message delivery to handler: key, value, headers (all
[]byte), plus topic/partition/offset/timestamp metadata
- HTTP health server for liveness and readiness probes (readiness tied to partition assignment)
- Same lifecycle hooks as HTTP/CloudEvents:
Start, Stop, Ready, Alive
- Configuration from environment variables:
KAFKA_BROKERS, KAFKA_TOPICS, KAFKA_CONSUMER_GROUP
PR: #169
Add a
kafka/package implementing a Kafka middleware for Knative Functions, following the same patterns as the existinghttp/andcloudevents/packages.[]byte), plus topic/partition/offset/timestamp metadataStart,Stop,Ready,AliveKAFKA_BROKERS,KAFKA_TOPICS,KAFKA_CONSUMER_GROUPPR: #169