Alai Kafka

create-topic

Create a new Kafka topic

Params

• partitions integer

  Number of partitions for the topic being created

• replication integer

  Replication factor for each partition in the topic

• topic string

  Topic name

Required

topic, partitions, replication

delete-topic

Delete a Kafka topic

Params

• topic string

  Topic name

Required

topic

list-topics

List all Kafka topics

list-zks

List ip:port info for connected Zookeeper servers

read-topic

Consume an existing kafka topic

Params

• partition integer

  Partition to consume

• topic string

  Topic name

Required

topic, partition

write-topic

Write to a kafka topic

Params

• data string

  Data to write to topic

• topic string

  Topic name

Required

topic, data