Skip to content

Commit 87a73a4

Browse files
authored
Update README.md
Add more user direction.
1 parent 6295eff commit 87a73a4

File tree

1 file changed

+11
-2
lines changed

1 file changed

+11
-2
lines changed

README.md

Lines changed: 11 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,12 +15,21 @@ The detail introduction docs available in [docs page](./docs/docs.md)
1515
- Clone from repo: `git clone https://github.com/databendcloud/databend-kafka-connect.git`
1616
- From the root of the project:
1717
- Build and package debezium server: `mvn -Passembly -Dmaven.test.skip package`
18-
- After building, you will get the jar file in `target` dir. Just put it into kafka libs dir.
18+
- After building, you will get the jar files in `target` dir. Or download the package jar files from [release](https://github.com/databendcloud/databend-kafka-connect/releases) Just put it into kafka libs dir.
1919
- Create `databend.properties` file in kafka config dir and config it: `nano config/databend.properties`, you can check the example
2020
configuration
2121
in [application.properties.example](src/main/resources/conf/application.properties.example)
2222
- config your source connect such as kafka mysql connector
23-
- Start or restart the Kafka Connect workers.: `bin/connect-standalone.sh config/connect-standalone.properties config/databend.properties config/mysql.properties`
23+
- if you sync data from kafka topic directly, please confirm the data format from kafka topic, for example, if your data if AVRO format, you should add the following config into config properties:
24+
25+
```
26+
key.converter=org.apache.kafka.connect.storage.StringConverter
27+
value.converter=io.confluent.connect.avro.AvroConverter
28+
value.converter.basic.auth.credentials.source=USER_INFO
29+
value.converter.schema.registry.basic.auth.user.info=xxxx
30+
value.converter.schema.registry.url=https://your-registry-url.us-east-2.aws.confluent.cloud
31+
```
32+
- Start or restart the Kafka Connect workers.: `bin/connect-standalone.sh config/connect-standalone.properties config/databend.properties config/mysql.properties`
2433

2534
More details about configure kafka connector, please read [Configure Self-Managed Connectors](https://docs.confluent.io/platform/current/connect/configuring.html).
2635

0 commit comments

Comments
 (0)