Operations

Zoe can do much more than just producing and consuming data from Kafka. In this section, you will find examples of some additional capabilities of zoe.

Interacting with consumer groups

Fetch the offsets and lags of a specific consumer group :

CommandOutput

zoe -o table -v -c my-cluster groups offsets my-consumer-group-name

┌──────────┬───────────┬───────────────┬───────────┬─────┬──────────┐
│ topic    │ partition │ currentOffset │ endOffset │ lag │ metadata │
├──────────┼───────────┼───────────────┼───────────┼─────┼──────────┤
│ my-topic │ 3         │ 49993793      │ 49993793  │ 0   │          │
├──────────┼───────────┼───────────────┼───────────┼─────┼──────────┤
│ my-topic │ 4         │ 50275990      │ 50275991  │ 1   │          │
├──────────┼───────────┼───────────────┼───────────┼─────┼──────────┤
│ my-topic │ 1         │ 50155761      │ 50155762  │ 1   │          │
├──────────┼───────────┼───────────────┼───────────┼─────┼──────────┤
│ my-topic │ 2         │ 50212574      │ 50212574  │ 0   │          │
├──────────┼───────────┼───────────────┼───────────┼─────┼──────────┤
│ my-topic │ 0         │ 50027346      │ 50027347  │ 1   │          │
└──────────┴───────────┴───────────────┴───────────┴─────┴──────────┘

Consumer groups can also be given aliases in zoe's configuration. This is done in the groups section inside the cluster configuration. Refer to the configuration reference section.

Use zoe groups --help for additional commands and examples to interact with consumer groups.

Interacting with the Avro Schema Registry

List avro schemas :

CommandOutput

zoe -o table -v -c my-cluster schemas list

┌───────────────────┐
│ subjects          │
├───────────────────┤
│ input-topic-value │
│ input-topic-key   │
└───────────────────┘

Describe a schema :

CommandOutput

zoe -o json -v -c my-cluster schemas describe input-topic-value

{
  "subject": "input-topic-value",
  "versions": [2],
  "latest": "{\"type\":\"record\",\"name\":\"my-schema\",\"namespace\":\"com.adevinta.example\",\"fields\":[...]}"
}

Deploy avro schema using an .avdl file :

Command

zoe -c my-cluster \
    schemas deploy \
    --avdl \
    --from-file schema.avdl \
    --name ModuleReason \
    --strategy topicRecord --topic input

Use zoe schemas --help for additional commands and help on interacting with schemas.