Advanced

Advanced section is experimental and requires deep understanding of the message exchanges between system components. For example, create a Kafka JSON request API to test Kafka response.

Advanced section defines the following CLI operations:

fluvio advanced <SUBCOMMAND>

SUBCOMMANDS:
    generate    Generate a request template
    run         Send request to server

Generate Kafka Requests 

Generate request operation creates a custom JSON template for a specific request. The template needs to be filled-in with additional information for a proper request.

fluvio advanced generate --request <>

OPTIONS:
    -r, --request <>    Request API [possible values: ApiVersions,                        
                        ListOffset, Metadata, 
                        LeaderAndIsr, FindCoordinator,
                        JoinGroup, SyncGroup, LeaveGroup, 
                        ListGroups, DescribeGroups, DeleteGroups, 
                        Heartbeat, OffsetFetch]
  • --request <>: is a list of requests supported by the CLI. Request is a mandatory option.

Generate Kafka Request Example 

… Fluvio

Run Kafka Requests 

Run request operation with a properly formatted JSON file against a Kafka server.

fluvio advanced run [OPTIONS] --json-file <file.json> --request <>

OPTIONS:
    -r, --request <>              Request API [possible values: ApiVersions,
                                  ListOffset, Metadata, 
                                  LeaderAndIsr, FindCoordinator,
                                  JoinGroup, SyncGroup, LeaveGroup, 
                                  ListGroups, DescribeGroups, DeleteGroups, 
                                  Heartbeat, OffsetFetch]
    -k, --kf <host:port>          Address of Kafka Controller
    -j, --json-file <file.json>   Request details file
    -P, --profile <profile>       Profile name

The options are defined as follows:

  • --request <>: is a list of requests supported by the CLI. Request is a mandatory option.

  • --kf <host:port>: is the interface of the Kafka Controller. The Kf is an optional field used in combination with CLI Profiles to compute a target service.

  • --json-file <file.json>: is the JSON file for the request type. JSON file is a mandatory option.

  • --profile <profile>: is the custom-defined profile file. The profile is an optional field used to compute a target service. For additional information, see Target Service section.

… Fluvio