Skip to content

Commit

Permalink
add Readme.md
Browse files Browse the repository at this point in the history
  • Loading branch information
CanerPatir committed Dec 30, 2022
1 parent 1d3a9a0 commit 7006bb0
Show file tree
Hide file tree
Showing 2 changed files with 41 additions and 0 deletions.
40 changes: 40 additions & 0 deletions README.md
Original file line number Diff line number Diff line change
@@ -0,0 +1,40 @@
go-kafka-couchbase-connector
============================

### Usage

```
$ go get github.com/Trendyol/go-kafka-connect-couchbase
```
---
### Example

```
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()
}
```
---

### Examples

- [example](example/main.go)
- [static membership config](example/config.yml)
- [kubernetesStatefulSet membership config](example/config_k8s_stateful_set.yml)
- [kubernetesHa membership config](example/config_k8s_leader_election.yml)
1 change: 1 addition & 0 deletions example/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@ import (
)

func mapper(event *couchbase.Event) *kafka.Message {
// return nil if you wish filter the event
return &kafka.Message{
Key: event.Key,
Value: event.Value,
Expand Down

0 comments on commit 7006bb0

Please sign in to comment.