We are hiring! Apply here
Inbound Kafka Connector

The inbound Kafka Connector will send every record on a Kafka topic/partition to a Fluvio topic/partition.

 

Common config values

type: kafka-source
version: 0.2.0
 

Parameters

The inbound Kafka connector supports the following configuration options:

 

kakfa-url

required

The url of the Kafka instance to connect to.

 

kafka-topic

Default: Same name as the configured fluvio topic

The name of the Kafka topic name to connect to.

 

kafka-partition

Default: 0

The Kafka partition to connect to.

 

kafka-group

Default: fluvio-kafka-source

The Kafka group

 

Example connector config

version: 0.2.0
name: my-inbound-kafka
type: kafka-source
topic: fluvio-output-topic
parameters:
 kafka-url: "localhost:9092"
 kafka-topic: kafka-input-topic
 kafka-partition: 0
 

Data Events

Events are sent to Fluvio as raw bytes. The event records are sent along to Fluvio as well.