Skip to content

Groups

Jump to bottom
Jimmy Bonds edited this page Dec 19, 2018 · 3 revisions

kafkactl Group Mgmt:

Searching for Groups:

  • Listing all Groups:

Running "kafkactl groups" without any other arguments will return all groups found.

# > kafkactl groups

GROUPTYPE  GROUP                      COORDINATOR
consumer   kafkaconsumer01            atl-dc-kafka01.jbvm.io:9092/3
consumer   myConsumerGroup            atl-dc-kafka03.jbvm.io:9092/4
consumer   kafkaGrp                   atl-dc-kafka02.jbvm.io:9092/4
consumer   console-consumer-slkj12    atl-dc-kafka01.jbvm.io:9092/3
consumer   emitterGroupDev            atl-dc-kafka05.jbvm.io:9092/4
consumer   kafkaconsumer02            atl-dc-kafka03.jbvm.io:9092/3
  • Quick Search:
# > kafkactl groups myConsumerGroup

GROUPTYPE  GROUP            COORDINATOR
consumer   myConsumerGroup  atl-dc-kafka03.jbvm.io:9092/4
  • Search by Group and Topic / Get More Group Details / Lag:
# > kafkactl groups myConsumerGroup -t my.target.topic --lag

GROUP               TOPIC            PART  MEMBER                       OFFSET  LAG
myConsumerGroup     my.target.topic  4     myConsumerGroup-47747-7ovmv  161747  0
myConsumerGroup     my.target.topic  10    myConsumerGroup-47747-po9lz  161210  0
myConsumerGroup     my.target.topic  12    myConsumerGroup-47747-pog2b  160992  0
myConsumerGroup     my.target.topic  0     myConsumerGroup-47747-0ofzd  163071  0
myConsumerGroup     my.target.topic  13    myConsumerGroup-47747-sorl6  162532  0
myConsumerGroup     my.target.topic  6     myConsumerGroup-47747-how5f  164901  0
myConsumerGroup     my.target.topic  1     myConsumerGroup-47747-2otd3  161718  0
myConsumerGroup     my.target.topic  14    myConsumerGroup-47747-so5gs  163113  0
myConsumerGroup     my.target.topic  8     myConsumerGroup-47747-lodh7  159843  0
myConsumerGroup     my.target.topic  9     myConsumerGroup-47747-no4lc  163850  0
myConsumerGroup     my.target.topic  5     myConsumerGroup-47747-bo6mc  164365  0
myConsumerGroup     my.target.topic  2     myConsumerGroup-47747-4omxm  163141  0
myConsumerGroup     my.target.topic  11    myConsumerGroup-47747-po0fp  163338  0
myConsumerGroup     my.target.topic  7     myConsumerGroup-47747-jow8s  163729  0
myConsumerGroup     my.target.topic  3     myConsumerGroup-47747-5olhn  161977  0
  • Find Groups by Topic:
# > kafkactl groups -t my.target.topic

GROUP             TOPIC            PART  MEMBER
emitterGroupDev   my.target.topic  0-14  emitter-entity-42267437-7ftms
myConsumerGroup   my.target.topic  2     myConsumerGroup-47747-4okmxm
myConsumerGroup   my.target.topic  12    myConsumerGroup-47747-pong2b
myConsumerGroup   my.target.topic  5     myConsumerGroup-47747-bo46mc
myConsumerGroup   my.target.topic  13    myConsumerGroup-47747-soprl6
myConsumerGroup   my.target.topic  1     myConsumerGroup-47747-2omtd3
myConsumerGroup   my.target.topic  3     myConsumerGroup-47747-5o6lhn
myConsumerGroup   my.target.topic  4     myConsumerGroup-47747-7o6vmv
myConsumerGroup   my.target.topic  9     myConsumerGroup-47747-noq4lc
myConsumerGroup   my.target.topic  11    myConsumerGroup-47747-pod0fp
myConsumerGroup   my.target.topic  7     myConsumerGroup-47747-jovw8s
myConsumerGroup   my.target.topic  10    myConsumerGroup-47747-po09lz
myConsumerGroup   my.target.topic  14    myConsumerGroup-47747-sov5gs
myConsumerGroup   my.target.topic  0     myConsumerGroup-47747-0okfzd
myConsumerGroup   my.target.topic  6     myConsumerGroup-47747-holw5f
myConsumerGroup   my.target.topic  8     myConsumerGroup-47747-losdh7
  • Search Groups by Client ID:
# > kafkactl groups -i myConsumerGroup-47747-sov5gs --lag

GROUP            TOPIC            PART  MEMBER                        OFFSET  LAG
myConsumerGroup  my.target.topic  14    myConsumerGroup-47747-sov5gs  548751  1
myConsumerGroup  my.target.topic  14    myConsumerGroup-47747-sov5gs  200366  1
myConsumerGroup  my.target.topic  14    myConsumerGroup-47747-sov5gs  163113  0
myConsumerGroup  my.target.topic  14    myConsumerGroup-47747-sov5gs  63328   0

Deleting a Group:

  • There will be no confirmation or warnings when deleting a group!
  • Groups must be inactive otherwise they will not be deleted.
# > kafkactl admin delete -g myConsumerGroup
Clone this wiki locally