The Kafka Connector is quite simple. It will send every record on a kafka topic/partition to a fluvio topic/partition.
# kafka-source-connector.yml name: my-kafka-source type: kafka-source topic: fluvio-output-topic parameters: kafka-url: "localhost:9092" # or something kafka-topic: kafka-input-topic
kafka-topicis optional and will default to the top level
topicwhich is the topic used on the fluvio side of things.
kafka-partitionis option and will default to
This configuration file is used together with the
fluvio connector create command, like so:
$ fluvio connector create --config=./kafka-source-connector.yml
Events are sent to fluvio as raw bytes. The record are sent along to fluvio as well.