Fluvio Kafka Inbound Connector
This is a connector for taking data from a Kafka topic and sending to a Fluvio topic.
See docs here.
| Opt | default | type | description |
|---|---|---|---|
| url | - | String | The url for the kafka connector |
| topic | - | String | The kafka topic |
| partition | 0 | Integer | The kafka partition |
| group | fluvio-kafka-source | String | The kafka consumer group |
Example:
apiVersion: 0.1.0
meta:
version: 0.2.5
name: my-kafka-connector
type: kafka-source
topic: kafka-topic
create-topic: true
kafka:
url: "localhost:9092"
topic: fluvio-topic
To try out Kafka Source connector locally, you can use Fluvio CDK tool:
fluvio install cdk
cdk deploy -p kafka-source start --config crates/kafka-source/sample-config.yaml
Fluvio Kafka Connectors support Transformations.
