Skip to content

Commit

Permalink
Exchange SST mode doesn't apply to Kafka and other streaming data sou…
Browse files Browse the repository at this point in the history
…rces (#2120)
  • Loading branch information
cooper-lzy authored Jun 12, 2023
1 parent e58b2bc commit 1dd2d28
Show file tree
Hide file tree
Showing 2 changed files with 12 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -40,6 +40,10 @@ Before importing data, you need to confirm the following information:

- The Kafka service has been installed and started.

## Precautions

Only client mode is supported when importing Kafka data, i.e. the value of parameters `tags.type.sink` and `edges.type.sink` is `client`.

## Steps

### Step 1: Create the Schema in NebulaGraph
Expand Down Expand Up @@ -149,7 +153,7 @@ After Exchange is compiled, copy the conf file `target/classes/application.conf`
type: {
# Specify the data source file format to Kafka.
source: kafka
# Specify how to import the data into NebulaGraph: Client or SST.
# Specify how to import the data into NebulaGraph. Only client is supported.
sink: client
}
# Kafka server address.
Expand Down Expand Up @@ -222,7 +226,7 @@ After Exchange is compiled, copy the conf file `target/classes/application.conf`
source: kafka
# Specify how to import the Edge type data into NebulaGraph.
# Specify how to import the data into NebulaGraph: Client or SST.
# Specify how to import the data into NebulaGraph. Only client is supported.
sink: client
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -32,6 +32,10 @@ Before importing data, you need to confirm the following information:

- The Pulsar service has been installed and started.

## Precautions

Only client mode is supported when importing Pulsar data, i.e. the value of parameters `tags.type.sink` and `edges.type.sink` is `client`.

## Steps

### Step 1: Create the Schema in NebulaGraph
Expand Down Expand Up @@ -138,7 +142,7 @@ After Exchange is compiled, copy the conf file `target/classes/application.conf`
type: {
# Specify the data source file format to Pulsar.
source: pulsar
# Specify how to import the data into NebulaGraph: Client or SST.
# Specify how to import the data into NebulaGraph. Only client is supported.
sink: client
}
# The address of the Pulsar server.
Expand Down Expand Up @@ -211,7 +215,7 @@ After Exchange is compiled, copy the conf file `target/classes/application.conf`
source: pulsar
# Specify how to import the Edge type data into NebulaGraph.
# Specify how to import the data into NebulaGraph: Client or SST.
# Specify how to import the data into NebulaGraph. Only client is supported.
sink: client
}
Expand Down

0 comments on commit 1dd2d28

Please sign in to comment.