This Week in Fluvio #16

Dec 1, 2021

Welcome to This Week in Fluvio, our weekly newsletter for development updates to Fluvio open source. Fluvio is a distributed, programmable streaming platform written in Rust.


New Release - Fluvio v0.9.14


Connector logs

Logs from connectors are now accessible from the CLI

fluvio connector logs <connector name>

In this example output, we can see some error output from the connector that would have previously been inaccessible.


$ fluvio connector logs my-test-mqtt -f

2021-12-15T05:20:21.770042Z ERROR mqtt: Mqtt error MqttState(Deserialization(PayloadSizeLimitExceeded(16635)))
2021-12-15T05:20:27.684853Z ERROR mqtt: Mqtt error MqttState(Deserialization(PayloadSizeLimitExceeded(16635)))

CLI Consumer wait spinner

Using the CLI consumer now has a new spinner to give feedback about the stream waiting for data.

Here’s a short clip of the spinner in action with streaming data.


Change to multi-word subcommands

Given that these are still long commands, we’ve added aliases too

Previous subcommand New subcommand New alias
smartmodule smart-module sm
tableformat table-format tf
derivedstream derived-stream ds

CLI shell autocompletions

This actually isn’t new, but it was hidden. Thanks to bohlmannc for helping us resolve this!

$ fluvio completions -h
fluvio-completions 0.0.0
Generate command-line completions for Fluvio

Run the following two commands to enable fluvio command completions.

Open a new terminal for the changes to take effect.

$ fluvio completions bash > ~/
$ echo "source ~/" >> ~/.bashrc

    fluvio completions <SUBCOMMAND>

    -h, --help    Prints help information

    bash    Generate CLI completions for bash
    fish    Generate CLI completions for fish
    help    Prints this message or the help of the given subcommand(s)

Get in touch with us on Github Discussions or join our Discord channel and come say hello!

For the full list of changes this week, be sure to check out our CHANGELOG.

Until next week!