Use Fluvio topics as sources and sinks
Field | Description | Required | Example |
---|---|---|---|
endpoint | The endpoint of your Fluvio cluster; if not specified the default profile is used | No | my-cluster:9003 |
topic | The name of the Fluvio topic to read from or write to | Yes | |
type | The type of table (either ‘source’ or ‘sink’) | Yes | source |
source.offset | The offset to start reading from (either ‘earliest’ or ‘latest’) | If source | earliest |