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

type: kafka-source

version: 0.3.2

The inbound Kafka connector supports the following configuration options:

required

The url of the Kafka instance to connect to.

Default: Same name as the configured fluvio topic

The name of the Kafka topic name to connect to.

Default: 0

The Kafka partition to connect to.

Default: fluvio-kafka-source

The Kafka group

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

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