stuffer.contrib.kafka module

class stuffer.contrib.kafka.Install(version, scala_version='2.12', destination='/opt')[source]

Bases: stuffer.core.Action

prerequisites()[source]
run()[source]

Run the Action command(s).

The default implementation runs the command returned by command().

str
The output of the command
subprocess.CalledProcessError
On execution failure.