A Kafka Connect plugin for transferring data between Crux nodes and Kafka.
The Crux source connector will publish transacations on a node to a Kafka topic, and the sink connector can receive transactions from a Kafka topic and submit them to a node.
| Data format | Sink/Source |
|---|---|
JSON | Both |
Avro | Sink |
Transit | Source |
EDN | Both |
To get started with the connector, there are two separate guides (depending on whether you are using a full Confluent Platform installation, or a basic Kafka installation):
Destination URL of Crux HTTP end point
Type: String
Importance: High
Default: "http://localhost:3000"
The Kafka topic to publish data to
Type: String
Importance: High
Default: "connect-test"
Format to send data out as: edn, json or transit
Type: String
Importance: Low
Default: "edn"
Mode to use: tx or doc
Type: String
Importance: Low
Default: "tx"
The maximum number of records the Source task can read from Crux at one time.
Type: Int
Importance: LOW
Default: 2000
Destination URL of Crux HTTP end point
Type: String
Importance: High
Default: "http://localhost:3000"
Record key to use as :crux.db/id
Type: String
Importance: Low
Default: "crux.db/id"
Can you improve this documentation?Edit on GitHub
cljdoc builds & hosts documentation for Clojure/Script libraries
| Ctrl+k | Jump to recent docs |
| ← | Move to previous article |
| → | Move to next article |
| Ctrl+/ | Jump to the search field |