MASES.KNetCLI 1.2.0

KNetCLI

Installation

To install the tool follows the instructions on https://docs.microsoft.com/en-us/dotnet/core/tools/global-tools.

Usage

To use the CLI interface (KNetCLI) runs a command like the following:

KNetCLI -ClassToRun ConsoleConsumer --bootstrap-server SERVER-ADDRESS:9093 --topic topic_name --from-beginning

KNetCLI accepts the following command-line switch:

• ClassToRun: represents the class to be executed; the list is:
  • Administration scope:
    • AclCommand
    • BrokerApiVersionsCommand
    • ConfigCommand
    • ConsumerGroupCommand
    • DelegationTokenCommand
    • DeleteRecordsCommand
    • FeatureCommand
    • LeaderElectionCommand
    • LogDirsCommand
    • ReassignPartitionsCommand
    • TopicCommand
    • ZkSecurityMigrator
  • Server scope:
    • KafkaStart
    • ZooKeeperShell
    • ZooKeeperStart
  • Shell scope:
    • MetadataShell
  • Tools scope:
    • ClusterTool
    • ConsoleConsumer
    • ConsoleProducer
    • ConsumerPerformance
    • DumpLogSegments
    • GetOffsetShell
    • MirrorMaker
    • ProducerPerformance
    • ReplicaVerificationTool
    • StorageTool
    • StreamsResetter
    • TransactionsCommand
    • VerifiableConsumer
    • VerifiableProducer
• KafkaLocation: represents the path to the root folder of Apache Kafka binary distribution; default value consider that KNetCLI uses the Apache Kafka jars available under the jars folder prepared from the package;
• ScalaVersion: the scala version to be used. The default version (2.13.6) is binded to the deafult Apache Kafka version available in the package;
• Log4JConfiguration: the log4j configuration file; the default uses the file within the package.