sdk-go
sdk-go copied to clipboard
Cloudevents support for Segmentio/kafka-go library
Implement Kafka binding for segmentio/kafka-go library similar to what is done here: https://github.com/cloudevents/sdk-go/pull/314
Note: This is an enhancement request and I am up for adding this.
has any progress?
has any progress? Made some changes here: https://github.com/cloudevents/sdk-go/pull/719 I tested it locally it works as expected. I need to add some unit tests for sender.