Usage: kafka-util <topics|consumerGroups|replication-config|delete-replication-config|replication-connector-tasks>
  This command can be used to manage topics, consumerGroups, replication configuration and
  replication connector tasks. It supports the following sub commands:
 
  topics                                 : Manage topics in kafka
     options:
      --list                             : List all the topics currently in kafka
      --describe [--topic <topic_names>] : Describe all or a specific topic
      --delete <topic_name>              : Delete a topic 
 
  consumerGroups                         : Manage consumerGroups in kafka
     options:
      --list                             : List all consumer groups
      --describe   (--group <group_name> | --all-groups) [ --members| --state ]  : Describe all or a specific consumer group given by the --group option.
      --reset-offsets  (--group <group_name> | --all-groups)  (--topic <topic_name> | --all-topics) (--by-duration 'PnDTnHnMnS'|--to-offset <offset-number> |--to-datetime 'YYYY-MM-DDTHH:mm:SS.sss'|--to-earliest|--to-current|--shift-by <number-of-offsets> |--to-latest ) (--execute|--dry-run) : Reset offsets on consumer groups
     
     sub-options:
      --group <group-name>               : To act on a specific group. Used only with --reset-offsets and --describe options
      --all-groups                       : To act on all groups. Used only with --reset-offsets and --describe options
      --members                          : Describe members of the group or all groups. Used only with --describe option
      --state                            : Describe state of the group or all groups. Used only with --describe option
      --all-topics                       : to act on all topics. Used only with --reset-offsets option
      --topic <topic_name>               : to act on a specific topic. Used only with  --reset-offsets option
 
  replication-config
     options: [ all options are required for this subcommand ]
      -ldc|--local-datacenter <datacenter_name> : local data center name. No spaces allowed in the name
      -lbs|--local-bootstrap-server <bootstrap_server> : local bootstrap server
      -lc |--local-cluster <FQDN/IP>     : local cluster FQDN or IP address
      -rdc|--remote-datacenter <datacenter_name> : remote data center name. No spaces allowed in the name
      -rbs|--remote-bootstrap-server <bootstrap_server> : remote bootstrap server
      -rc |--remote-cluster <FQDN/IP>    : remote cluster FQDN or IP address
 
  delete-replication-config              : sub commmand to delete replication configuration
     options:
      -lc|--local-cluster <FQDN/IP>      : local cluster FQDN or IP address (required option)
 
 replication-connector-tasks             : sub command to view and set max connector tasks
     options:
      --view                             : See the connector tasks details
      --set-max-tasks <max-tasks-value>  : Sets the maximum tasks value for replication connector
 
 certificate-update-restart              : this sub command restarts kafka after certificate updates
  
 Example  commands
  kafka-util topics --list
  kafka-util topics --describe --topic my_topic
  kafka-util topics --delete my_topic
 
  kafka-util consumerGroups --list
  kafka-util consumerGroups --describe --group my_group --state
  kafka-util consumerGroups --reset-offsets --group my_group --topic my_topic --to-earliest --dry-run
 
  kafka-util replication-config -ldc my_localDC -lbs my_lbs_server -lc 10.129.1.20 -rdc my_remoteDC -rbs my_rbs_server -rc 10.130.1.20
  kafka-util delete-replication-config -lc 10.129.1.20
   
  kafka-util replication-connector-tasks --view
  kafka-util replication-connector-tasks --set-max-tasks 100