Generate connector yaml

Makefile

@@ -2,7 +2,8 @@ VERSION=$(shell git describe --tags --dirty --always)
 
 .PHONY: build
 build:
-	go build -ldflags "-X 'github.com/conduitio/conduit-connector-kafka.version=${VERSION}'" -o conduit-connector-kafka cmd/connector/main.go
+	sed -i '/specification:/,/version:/ s/version: .*/version: '"${VERSION}"'/' connector.yaml
+	go build -o conduit-connector-kafka cmd/connector/main.go
 
 .PHONY: test-kafka
 test-kafka:

common/config.go

@@ -43,13 +43,13 @@ type Config struct {
 }
 
 // Validate executes manual validations beyond what is defined in struct tags.
-func (c Config) Validate() error {
+func (c Config) Validate(ctx context.Context) error {
 	var multierr []error
 
-	if err := c.ConfigSASL.Validate(); err != nil {
+	if err := c.ConfigSASL.Validate(ctx); err != nil {
 		multierr = append(multierr, err)
 	}
-	if err := c.ConfigTLS.Validate(); err != nil {
+	if err := c.ConfigTLS.Validate(ctx); err != nil {
 		multierr = append(multierr, err)
 	}
 

common/config_test.go

@@ -76,7 +76,7 @@ func TestConfig_Validate(t *testing.T) {
 	for _, tc := range testCases {
 		t.Run(tc.name, func(t *testing.T) {
 			is := is.New(t)
-			err := tc.cfg.Validate()
+			err := tc.cfg.Validate(context.Background())
 			is.True(err != nil)
 			if actualErr, ok := tc.wantErr.(error); ok {
 				is.True(errors.Is(err, actualErr))

common/sasl.go

@@ -15,6 +15,7 @@
 package common
 
 import (
+	"context"
 	"errors"
 	"fmt"
 
@@ -36,7 +37,7 @@ type ConfigSASL struct {
 }
 
 // Validate executes manual validations beyond what is defined in struct tags.
-func (c ConfigSASL) Validate() error {
+func (c ConfigSASL) Validate(context.Context) error {
 	var multierr []error
 
 	if _, err := c.sasl(); err != nil {

common/tls.go

@@ -15,6 +15,7 @@
 package common
 
 import (
+	"context"
 	"crypto/tls"
 	"crypto/x509"
 	"fmt"
@@ -36,7 +37,7 @@ type ConfigTLS struct {
 }
 
 // Validate executes manual validations beyond what is defined in struct tags.
-func (c ConfigTLS) Validate() error {
+func (c ConfigTLS) Validate(context.Context) error {
 	_, err := c.tls()
 	return err
 }

connector.go

@@ -12,16 +12,23 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
+//go:generate specgen
+
 // Package kafka contains implementations for Kafka source and destination
 // connectors for Conduit.
 package kafka
 
 import (
+	_ "embed"
+
 	sdk "github.com/conduitio/conduit-connector-sdk"
 )
 
+//go:embed connector.yaml
+var specs string
+
 var Connector = sdk.Connector{
-	NewSpecification: Specification,
+	NewSpecification: sdk.YAMLSpecification(specs),
 	NewSource:        NewSource,
 	NewDestination:   NewDestination,
 }