From 970c0a77c6fdbc58d447a4fc0a6c56b6f2265aa0 Mon Sep 17 00:00:00 2001 From: myan Date: Fri, 26 Jan 2024 10:40:33 +0800 Subject: [PATCH] proposal the confluent binding for kafka Signed-off-by: myan --- docs/protocol_implementations.md | 2 ++ 1 file changed, 2 insertions(+) diff --git a/docs/protocol_implementations.md b/docs/protocol_implementations.md index e22e82894..5d154b11b 100644 --- a/docs/protocol_implementations.md +++ b/docs/protocol_implementations.md @@ -24,6 +24,8 @@ the `Write` functions, while the latter is done implementing spec * [AMQP Protocol Binding](https://github.com/cloudevents/sdk-go/tree/main/protocol/amqp) using [go-amqp](https://github.com/Azure/go-amqp) * [HTTP Protocol Binding](https://github.com/cloudevents/sdk-go/tree/main/v2/protocol/http) using [net/http](https://golang.org/pkg/net/http/) * [Kafka Protocol Binding](https://github.com/cloudevents/sdk-go/tree/main/protocol/kafka_sarama) using [Sarama](https://github.com/Shopify/sarama) +* [Kafka Protocol Binding](https://github.com/cloudevents/sdk-go/tree/main/protocol/kafka_confluent) using [confluent-kafka-go](https://github.com/confluentinc/confluent-kafka-go) + > It bring some new features compared the above [sarama](https://github.com/Shopify/sarama) binding. Like [pattern subscription](https://github.com/confluentinc/confluent-kafka-go/issues/96), [async message confirmation](https://github.com/cloudevents/sdk-go/issues/846) and other enhancements. * [MQTT Protocol Binding](https://github.com/cloudevents/sdk-go/tree/main/protocol/mqtt_paho) using [eclipse/paho.golang](https://github.com/eclipse/paho.golang) * [NATS Protocol Binding](https://github.com/cloudevents/sdk-go/tree/main/protocol/nats) using [nats.go](https://github.com/nats-io/nats.go) * [STAN Protocol Binding](https://github.com/cloudevents/sdk-go/tree/main/protocol/stan) using [stan.go](https://github.com/nats-io/stan.go)