remove kafka supprot

Signed-off-by: Wei Liu <liuweixa@redhat.com>

Author: skeeey

Makefile

@@ -12,17 +12,17 @@ include $(addprefix ./vendor/github.com/openshift/build-machinery-go/make/, \
 GO_PACKAGES :=$(addsuffix ...,$(addprefix ./,$(filter-out test/, $(filter-out vendor/,$(filter-out hack/,$(wildcard */))))))
 GO_BUILD_PACKAGES :=$(GO_PACKAGES)
 GO_BUILD_PACKAGES_EXPANDED :=$(GO_BUILD_PACKAGES)
-GO_BUILD_FLAGS :=-trimpath -tags=kafka
-GO_TEST_FLAGS :=-race -tags=kafka
+GO_BUILD_FLAGS :=-trimpath
+GO_TEST_FLAGS :=-race
 # LDFLAGS are not needed for dummy builds (saving time on calling git commands)
 GO_LD_FLAGS:=
 
 verify-gocilint:
 	go install github.com/golangci/golangci-lint/cmd/golangci-lint@v1.64.6
-	${GOPATH}/bin/golangci-lint run --build-tags=kafka --timeout=3m ./...
+	${GOPATH}/bin/golangci-lint run --timeout=3m ./...
 
 verify-govet:
-	go vet -mod=vendor -tags=kafka ./...
+	go vet -mod=vendor ./...
 
 verify: verify-gocilint
 

README.md

@@ -22,7 +22,6 @@ The SDK includes comprehensive CloudEvents-based clients for implementing event-
 **Supported Protocols:**
 - MQTT Protocol/Driver
 - gRPC Protocol/Driver  
-- Kafka Protocol/Driver
 
 **Key Features:**
 - Generic CloudEvents clients for custom resources

go.mod

@@ -4,10 +4,8 @@ go 1.24.0
 
 require (
 	github.com/bwmarrin/snowflake v0.3.0
-	github.com/cloudevents/sdk-go/protocol/kafka_confluent/v2 v2.0.0-20240413090539-7fef29478991
 	github.com/cloudevents/sdk-go/protocol/mqtt_paho/v2 v2.0.0-20250922144431-372892d7c84d
 	github.com/cloudevents/sdk-go/v2 v2.16.2
-	github.com/confluentinc/confluent-kafka-go/v2 v2.3.0
 	github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc
 	github.com/eclipse/paho.golang v0.23.0
 	github.com/evanphx/json-patch/v5 v5.9.11
@@ -75,7 +73,6 @@ require (
 	github.com/rs/xid v1.4.0 // indirect
 	github.com/stoewer/go-strcase v1.3.0 // indirect
 	github.com/x448/float16 v0.8.4 // indirect
-	go.opencensus.io v0.24.0 // indirect
 	go.opentelemetry.io/otel v1.33.0 // indirect
 	go.opentelemetry.io/otel/trace v1.33.0 // indirect
 	go.uber.org/multierr v1.11.0 // indirect

go.sum

@@ -116,7 +116,6 @@ Currently, the CloudEvents options supports the following protocols/drivers:
 
 - [MQTT Protocol/Driver](./generic/options/mqtt)
 - [gRPC Protocol/Driver](./generic/options/grpc)
-- [Kafka Protocol/Driver](./generic/options/kafka)
 
 To create CloudEvents source/agent options for these supported protocols/drivers, developers need to provide configuration specific to the protocol/driver. The configuration format resembles the kubeconfig for the Kubernetes client-go but has a different schema.
 
@@ -148,31 +147,6 @@ clientKeyFile: /certs/client.key
 
 For detailed configuration options for the gRPC driver, refer to the [gRPC driver options package](https://github.com/open-cluster-management-io/sdk-go/blob/00a94671ced1c17d2ca2b5fad2f4baab282a7d3c/pkg/cloudevents/generic/options/grpc/options.go#L30-L40).
 
-### Kafka Protocol/Driver
-
-Kafka Protocol/Drive is not enabled by default. To enable it, add the `-tags=kafka` flag before the build.
-
-Here’s a sample configuration for Kafka in YAML:
-
-```yaml
-bootstrapServer: kafka.example.com:9092
-caFile: /certs/ca.crt
-clientCertFile: /certs/client.crt
-clientKeyFile: /certs/client.key
-```
-
-For detailed configuration options for the Kafka driver, refer to the [Kafka driver options package](./generic/options/kafka/options.go). You can also add advanced configurations supported by librdkafka. For instance, to set the maximum Kafka protocol request message size to 200,000 bytes, use the following configuration in YAML:
-
-```yaml
-bootstrapServer: kafka.example.com:9092
-caFile: /certs/ca.crt
-clientCertFile: /certs/client.crt
-clientKeyFile: /certs/client.key
-message.copy.max.bytes: 200000
-```
-
-For the complete list of supported configurations, refer to the [librdkafka documentation](https://github.com/confluentinc/librdkafka/blob/master/CONFIGURATION.md).
-
 ## Work Clients
 
 ### Building a ManifestWorkSourceClient on the hub cluster with SourceLocalWatcherStore

pkg/cloudevents/README.md

@@ -31,8 +31,6 @@ type GenericClientOptions[T generic.ResourceObject] struct {
 //
 //     GRPCOptions (*grpc.GRPCOptions): builds a generic cloudevents client with GRPC
 //
-//     KafkaOptions (*kafka.KafkaOptions): builds a generic cloudevents client with Kafka
-//
 //   - codec, the codec for resource
 //
 //   - clientID, the client ID for generic cloudevents client.

pkg/cloudevents/clients/options/generic.go

@@ -1,7 +1,6 @@
 package constants
 
 const (
-	ConfigTypeMQTT  = "mqtt"
-	ConfigTypeGRPC  = "grpc"
-	ConfigTypeKafka = "kafka"
+	ConfigTypeMQTT = "mqtt"
+	ConfigTypeGRPC = "grpc"
 )

pkg/cloudevents/constants/constants.go

@@ -16,7 +16,7 @@ The [`CloudEventsOptions`](../generic/options/options.go) interface defines an o
 For each event protocol, it needs to implement the `CloudEventsSourceOptions` and `CloudEventsAgentOptions`, the 
 `CloudEventsSourceOptions` will be used for building cloudevents source client and the `CloudEventsAgentOptions` will be used for building cloudevents agent client.
 
-Currently, the MQTT, Kafka and gRPC are implemented.
+Currently, the MQTT and gRPC are implemented.
 
 ```mermaid
 classDiagram
@@ -42,9 +42,6 @@ CloudEventsOptions <|-- CloudEventsAgentOptions
 CloudEventsSourceOptions <|.. mqttSourceOptions
 CloudEventsAgentOptions <|.. mqttAgentOptions
 
-CloudEventsSourceOptions <|.. kafkaSourceOptions
-CloudEventsAgentOptions <|.. kafkaAgentOptions
-
 CloudEventsSourceOptions <|.. grpcSourceOptions
 CloudEventsAgentOptions <|.. grpcAgentOptions
 ```