$ go get github.com/Trendyol/go-kafka-connect-couchbase
package main
func mapper(event *couchbase.Event) *kafka.Message {
// return nil if you wish filter the event
return &kafka.Message{
Key: event.Key,
Value: event.Value,
Headers: map[string]string{},
}
}
func main() {
connector := godcpkafkaconnector.NewConnector("./example/config.yml", mapper)
defer connector.Close()
connector.Start()
}
