Skip to content

Home

Jump to bottom
jbvmio edited this page Dec 13, 2018 · 10 revisions

kafkactl Examples:

Increase Partitions and/or Replication Factor on a Topic:

# > kafkactl -b targetbroker01 topics my.target.topic -m
TOPIC            PART  OFFSET  LEADER  REPLICAS  ISRs  OFFLINE
my.target.topic  0     4755    2       [2]       [2]   []

# > kafkactl -b targetbroker01 admin increase -t my.target.topic -p 15
 Increase Partitions Successful for topic: my.target.topic

# > kafkactl -b targetbroker01 topics my.target.topic -m
TOPIC            PART  OFFSET  LEADER  REPLICAS  ISRs  OFFLINE
my.target.topic  0     4755    2       [2]       [2]   []
my.target.topic  1     0       3       [3]       [3]   []
my.target.topic  2     0       4       [4]       [4]   []
my.target.topic  3     0       5       [5]       [5]   []
my.target.topic  4     0       1       [1]       [1]   []
my.target.topic  5     0       2       [2]       [2]   []
my.target.topic  6     0       3       [3]       [3]   []
my.target.topic  7     0       4       [4]       [4]   []
my.target.topic  8     0       5       [5]       [5]   []
my.target.topic  9     0       1       [1]       [1]   []
my.target.topic  10    0       2       [2]       [2]   []
my.target.topic  11    0       3       [3]       [3]   []
my.target.topic  12    0       4       [4]       [4]   []
my.target.topic  13    0       5       [5]       [5]   []
my.target.topic  14    0       1       [1]       [1]   []

# > kafkactl -b targetbroker01 admin increase -t my.target.topic -r 3
 Successfully Started Reassign Partition Process.

# > kafkactl -b targetbroker01 topics my.target.topic -m
TOPIC            PART  OFFSET  LEADER  REPLICAS  ISRs     OFFLINE
my.target.topic  0     4755    2       [2 5 4]   [2 4 5]  []
my.target.topic  1     0       3       [3 2 1]   [3 1 2]  []
my.target.topic  2     0       4       [4 3 1]   [4 1 3]  []
my.target.topic  3     0       5       [5 2 4]   [5 4 2]  []
my.target.topic  4     0       1       [1 3 5]   [1 5 3]  []
my.target.topic  5     0       2       [2 1 4]   [2 1 4]  []
my.target.topic  6     0       3       [3 2 5]   [3 2 5]  []
my.target.topic  7     0       4       [4 3 1]   [4 3 1]  []
my.target.topic  8     0       5       [5 2 4]   [5 2 4]  []
my.target.topic  9     0       1       [1 3 5]   [1 3 5]  []
my.target.topic  10    0       2       [2 1 4]   [2 1 4]  []
my.target.topic  11    0       3       [3 2 5]   [3 5 2]  []
my.target.topic  12    0       4       [4 3 1]   [4 1 3]  []
my.target.topic  13    0       5       [5 2 4]   [5 2 4]  []
my.target.topic  14    0       1       [1 3 5]   [1 5 3]  []
Clone this wiki locally