Narindergupta Kafka

alter-topic

Alter an existing Kafka topic

Params

• partitions integer

  Number of partitions for the topic being created

• topic string

  Topic name

Required

topic, partitions

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

debug

Collect debug data

list-topics

List all Kafka topics

list-zks

List ip:port info for connected Zookeeper servers

mirror-topics

Create a mirror for list of topic between kafka clusters

Params

• consumer-config string

  Base 64 encoded consumer config file

• producer-config string

  Base 64 encoded producer config file

• topics string

  Topic name needs to be mirrored

Required

producer-config, consumer-config, topics

ops-acl

Run ACL operations on the cluster

Params

• acloperations string

  Operations to be run on the Kafka cluster

Required

acloperations

perf-test

This will run the performance test on the kafka

Params

• messages integer

  Number of messages needs to created for testing.

• recordsize integer

  size of record in bytes used to send in topic.

• topic string

  Topic name to be used for running test. New topic would be created.

Required

topic, messages, recordsize

read-topic

Consume an existing kafka topic

Params

• partition integer

  Partition to consume

• topic string

  Topic name

Required

topic, partition

reassign-topics

Return configuration of topics to new broker when a cluster scales out

Params

• broker string

  broker ids for scale out brokers

• topics-json string

  Base 64 encoded Json file contains the topics reassignment

Required

broker, topics-json

reassign-topics-execute

Reaasign topics to new broker when a cluster scales out

Params

• reassign-partitions string

  Base 64 encoded Json file contains the partition reassignment

Required

reassign-partitions

smoke-test

Verify that Kafka is working as expected by listing zookeepers, then creating/listing/deleting a topic

upgrade-kafka

Upgrade kafka installation

write-topic

Write to a kafka topic

Params

• data string

  Data to write to topic

• topic string

  Topic name

Required

topic, data