Kafka topics

The CLI can view, create and modify topics.

View all topics 

The optional names flag wil display only the names of the topics, and if –unwrap then each topic name will be displayed on a new line as a simple text

lenses-cli topics [--names [--unwrap]]

View a specific topic 

lenses-cli topic --name=reddit_posts

Update a topic configuration 

lenses-cli topic update \
    --name="topic2" \
    --configs="{\"max.message.bytes\": \"1000020\"}"

Update from a file.


lenses-cli topic update ./topic.yaml

Example file.

name: topicName
replication: 1
partitions: 1
configs:
  max.message.bytes: "1000010"

Create topics 

lenses-cli topic create \
    --name="topicName" \
    --replication=1 \
    --partitions=1 \
    --configs="{\"max.message.bytes\": \"1000010\"}"

For a file:
lenses-cli topic create ./topic.yml

Example file.

name: topicName
replication: 1
partitions: 1
configs:
  max.message.bytes: "1000010"

Delete topics 

lenses-cli topic delete --name="topic2"