fix version in config

api/jsonschema/schema.json

@@ -547,10 +547,6 @@
           "$ref": "#/definitions/io.argoproj.common.SASLConfig",
           "description": "SASL configuration for the kafka client"
         },
-        "streamConfig": {
-          "description": "Optional configuration for the kafka, if specified, it will be merged with the default configuration in controller-config. It accepts a YAML format configuration, available fields include, \"maxRetry\", \"configVersion (sarama config version)\", \"requiredAcks\", \"replication\".",
-          "type": "string"
-        },
         "tls": {
           "$ref": "#/definitions/io.argoproj.common.TLSConfig",
           "description": "TLS configuration for the kafka client."
@@ -562,6 +558,10 @@
         "url": {
           "description": "URL to kafka cluster, multiple URLs separated by comma",
           "type": "string"
+        },
+        "version": {
+          "description": "Kafka version, sarama defaults to the oldest supported stable version",
+          "type": "string"
         }
       },
       "type": "object"

pkg/apis/eventbus/v1alpha1/kafka_eventbus.go

@@ -16,7 +16,7 @@ type KafkaConfig struct {
 	URL string `json:"url,omitempty" protobuf:"bytes,1,opt,name=url"`
 	// Kafka version, sarama defaults to the oldest supported stable version
 	// +optional
-	Version string `json:"url,omitempty" protobuf:"bytes,2,opt,name=version"`
+	Version string `json:"version,omitempty" protobuf:"bytes,2,opt,name=version"`
 	// Topic name, defaults to namespace_name.eventbus_name
 	// +optional
 	Topic string `json:"topic,omitempty" protobuf:"bytes,3,opt,name=topic"`