Kafka Connector

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

Configuration

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:

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.