Skip to main content
Version: 0.13.0 (stable)

Kafka Connector

This is a connector for taking data from a Kafka topic and sending to a Fluvio topic.

Configuration

Optdefaulttypedescription
url-StringThe url for the kafka connector
topic-StringThe kafka topic
partition0IntegerThe kafka partition
groupfluvio-kafka-sourceStringThe kafka consumer group

Example:

info

The connector version is marked with x.y.z. To find the latest version, run:

  • fluvio hub connector list
apiVersion: 0.1.0
meta:
  version: x.y.z
  name: my-kafka-connector
  type: kafka-source
  topic: kafka-topic
kafka:
  url: "localhost:9092"
  topic: fluvio-topic

Usage

To try out Kafka Source connector locally, you can use Fluvio CDK tool:

$ cdk deploy -p kafka-source start --config crates/kafka-source/sample-config.yaml

Transformations

Fluvio Kafka Connectors support Transformations.