MASES.KNetPS

2.9.2

KNet PowerShell command line interface is a PowerShell Module to use Apache Kafka and PowerShell side-by-side. With KNet PowerShell it is possible to:
- execute all tools of Apache Kafka within a PowerShell shell: Administration tools, Console Consumer, Console Producer, manage Apache Kafka Streams, activate Apache Kafka Connect, server side (start Kafka and ZooKeepe
KNet PowerShell command line interface is a PowerShell Module to use Apache Kafka and PowerShell side-by-side. With KNet PowerShell it is possible to:
- execute all tools of Apache Kafka within a PowerShell shell: Administration tools, Console Consumer, Console Producer, manage Apache Kafka Streams, activate Apache Kafka Connect, server side (start Kafka and ZooKeeper), etc
- create consumers and producers objects to interact with an Apache Kafka cluster
- send data to and receive data from an Apache Kafka cluster
- create a Kafka Admin Client object to manage an Apache Kafka cluster

More information within the project hosted on GitHub. Further information at https://github.com/masesgroup/KNet.
Show more

Minimum PowerShell version

5.1

Installation Options

Copy and Paste the following command to install this package using PowerShellGet More Info

Install-Module -Name MASES.KNetPS

Copy and Paste the following command to install this package using Microsoft.PowerShell.PSResourceGet More Info

Install-PSResource -Name MASES.KNetPS

You can deploy this package directly to Azure Automation. Note that deploying packages with dependencies will deploy all the dependencies to Azure Automation. Learn More

Manually download the .nupkg file to your system's default download location. Note that the file won't be unpacked, and won't include any dependencies. Learn More

Owners

Copyright

Copyright © MASES s.r.l. 2025

Package Details

FileList

  • MASES.KNetPS.nuspec
  • net462\System.Diagnostics.TextWriterTraceListener.dll
  • net462\config\connect-knet-sink.properties
  • jars\kafka-shell-3.9.1.jar
  • net462\System.Diagnostics.Tools.dll
  • net462\config\connect-knet-source.properties
  • MASES.KNetPS.psd1
  • jars\kafka-storage-3.9.1.jar
  • net462\System.Diagnostics.TraceSource.dll
  • net462\config\connect-log4j.properties
  • MASES.KNetPS.psm1
  • jars\kafka-storage-api-3.9.1.jar
  • net462\System.Diagnostics.Tracing.dll
  • net462\config\connect-mirror-maker.properties
  • jars\activation-1.1.1.jar
  • jars\kafka-streams-3.9.1.jar
  • net462\System.Drawing.Primitives.dll
  • net462\config\connect-standalone.properties
  • jars\animal-sniffer-annotations-1.19.jar
  • jars\kafka-tools-3.9.1.jar
  • net462\System.Dynamic.Runtime.dll
  • net462\config\consumer.properties
  • jars\aopalliance-repackaged-2.6.1.jar
  • jars\kafka-tools-api-3.9.1.jar
  • net462\System.Globalization.Calendars.dll
  • net462\config\knet-log4j.properties
  • jars\argparse4j-0.7.0.jar
  • jars\kafka-transaction-coordinator-3.9.1.jar
  • net462\System.Globalization.dll
  • net462\config\log4j.properties
  • jars\audience-annotations-0.12.0.jar
  • jars\kafka_2.13-3.9.1.jar
  • net462\System.Globalization.Extensions.dll
  • net462\config\producer.properties
  • jars\caffeine-2.9.3.jar
  • jars\knet-2.9.2.0.jar
  • net462\System.IO.Compression.dll
  • net462\config\README.md
  • jars\checker-compat-qual-2.5.5.jar
  • jars\listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar
  • net462\System.IO.Compression.ZipFile.dll
  • net462\config\server.properties
  • jars\commons-beanutils-1.9.4.jar
  • jars\lz4-java-1.8.0.jar
  • net462\System.IO.dll
  • net462\config\tools-log4j.properties
  • jars\commons-cli-1.4.jar
  • jars\maven-artifact-3.9.6.jar
  • net462\System.IO.FileSystem.dll
  • net462\config\trogdor.conf
  • jars\commons-collections-3.2.2.jar
  • jars\metrics-core-2.2.0.jar
  • net462\System.IO.FileSystem.DriveInfo.dll
  • net462\config\zookeeper.properties
  • jars\commons-digester-2.1.jar
  • jars\metrics-core-4.1.12.1.jar
  • net462\System.IO.FileSystem.Primitives.dll
  • net462\config\kraft\broker.properties
  • jars\commons-io-2.14.0.jar
  • jars\netty-buffer-4.1.119.Final.jar
  • net462\System.IO.FileSystem.Watcher.dll
  • net462\config\kraft\controller.properties
  • jars\commons-lang3-3.12.0.jar
  • jars\netty-codec-4.1.119.Final.jar
  • net462\System.IO.IsolatedStorage.dll
  • net462\config\kraft\README.md
  • jars\commons-logging-1.2.jar
  • jars\netty-common-4.1.119.Final.jar
  • net462\System.IO.MemoryMappedFiles.dll
  • net462\config\kraft\server.properties
  • jars\commons-validator-1.7.jar
  • jars\netty-handler-4.1.119.Final.jar
  • net462\System.IO.Pipes.dll
  • net462\jars\jnet-2.5.12.0.jar
  • jars\connect-api-3.9.1.jar
  • jars\netty-resolver-4.1.119.Final.jar
  • net462\System.IO.UnmanagedMemoryStream.dll
  • net8.0\C2JBridge.dll
  • jars\connect-basic-auth-extension-3.9.1.jar
  • jars\netty-transport-4.1.119.Final.jar
  • net462\System.Linq.dll
  • net8.0\C2JBridgeDesktop.dll
  • jars\connect-file-3.9.1.jar
  • jars\netty-transport-classes-epoll-4.1.119.Final.jar
  • net462\System.Linq.Expressions.dll
  • net8.0\IpAddressIdGenerator.dll
  • jars\connect-json-3.9.1.jar
  • jars\netty-transport-native-epoll-4.1.119.Final.jar
  • net462\System.Linq.Parallel.dll
  • net8.0\IpAddressIdGenerator.runtimeconfig.json
  • jars\connect-mirror-3.9.1.jar
  • jars\netty-transport-native-unix-common-4.1.119.Final.jar
  • net462\System.Linq.Queryable.dll
  • net8.0\J2CBridge_Arm.so
  • jars\connect-mirror-client-3.9.1.jar
  • jars\opentelemetry-proto-1.0.0-alpha.jar
  • net462\System.Management.Automation.dll
  • net8.0\J2CBridge_Arm64.dll
  • jars\connect-runtime-3.9.1.jar
  • jars\osgi-resource-locator-1.0.3.jar
  • net462\System.Net.Http.dll
  • net8.0\J2CBridge_Arm64.dylib
  • jars\connect-transforms-3.9.1.jar
  • jars\paranamer-2.8.jar
  • net462\System.Net.NameResolution.dll
  • net8.0\J2CBridge_Arm64.so
  • jars\error_prone_annotations-2.10.0.jar
  • jars\pcollections-4.0.1.jar
  • net462\System.Net.NetworkInformation.dll
  • net8.0\J2CBridge_x64.dll
  • jars\failureaccess-1.0.1.jar
  • jars\plexus-utils-3.5.1.jar
  • net462\System.Net.Ping.dll
  • net8.0\J2CBridge_x64.dylib
  • jars\grpc-api-1.35.0.jar
  • jars\proto-google-common-protos-2.0.1.jar
  • net462\System.Net.Primitives.dll
  • net8.0\J2CBridge_x64.so
  • jars\grpc-context-1.35.0.jar
  • jars\protobuf-java-3.25.5.jar
  • net462\System.Net.Requests.dll
  • net8.0\J2CBridge_x86.dll
  • jars\grpc-protobuf-1.35.0.jar
  • jars\reflections-0.10.2.jar
  • net462\System.Net.Security.dll
  • net8.0\JCOBridge.docs.jar
  • jars\grpc-protobuf-lite-1.35.0.jar
  • jars\reload4j-1.2.25.jar
  • net462\System.Net.Sockets.dll
  • net8.0\JCOBridge.jar
  • jars\grpc-stub-1.35.0.jar
  • jars\rocksdbjni-7.9.2.jar
  • net462\System.Net.WebHeaderCollection.dll
  • net8.0\LicenseManagerUI.dll
  • jars\guava-30.0-android.jar
  • jars\scala-collection-compat_2.13-2.10.0.jar
  • net462\System.Net.WebSockets.Client.dll
  • net8.0\LicenseManagerUI.runtimeconfig.json
  • jars\hk2-api-2.6.1.jar
  • jars\scala-java8-compat_2.13-1.0.2.jar
  • net462\System.Net.WebSockets.dll
  • net8.0\LicenseViewer.dll
  • jars\hk2-locator-2.6.1.jar
  • jars\scala-library-2.13.15.jar
  • net462\System.ObjectModel.dll
  • net8.0\LicenseViewer.runtimeconfig.json
  • jars\hk2-utils-2.6.1.jar
  • jars\scala-logging_2.13-3.9.5.jar
  • net462\System.Reflection.dll
  • net8.0\MachineIdGenerator.dll
  • jars\j2objc-annotations-1.3.jar
  • jars\scala-reflect-2.13.15.jar
  • net462\System.Reflection.Extensions.dll
  • net8.0\MachineIdGenerator.runtimeconfig.json
  • jars\jackson-annotations-2.16.2.jar
  • jars\slf4j-api-1.7.36.jar
  • net462\System.Reflection.Primitives.dll
  • net8.0\MASES.CLIParser.dll
  • jars\jackson-core-2.16.2.jar
  • jars\slf4j-reload4j-1.7.36.jar
  • net462\System.Resources.Reader.dll
  • net8.0\MASES.JNet.dll
  • jars\jackson-databind-2.16.2.jar
  • jars\snappy-java-1.1.10.5.jar
  • net462\System.Resources.ResourceManager.dll
  • net8.0\MASES.JNetPSCore.dll
  • jars\jackson-dataformat-csv-2.16.2.jar
  • jars\swagger-annotations-2.2.8.jar
  • net462\System.Resources.Writer.dll
  • net8.0\MASES.KNet.dll
  • jars\jackson-datatype-jdk8-2.16.2.jar
  • jars\trogdor-3.9.1.jar
  • net462\System.Runtime.CompilerServices.Unsafe.dll
  • net8.0\MASES.KNet.pdb
  • jars\jackson-jaxrs-base-2.16.2.jar
  • jars\zookeeper-3.8.4.jar
  • net462\System.Runtime.CompilerServices.VisualC.dll
  • net8.0\MASES.KNet.xml
  • jars\jackson-jaxrs-json-provider-2.16.2.jar
  • jars\zookeeper-jute-3.8.4.jar
  • net462\System.Runtime.dll
  • net8.0\MASES.KNetPS.deps.json
  • jars\jackson-module-afterburner-2.16.2.jar
  • jars\zstd-jni-1.5.6-4.jar
  • net462\System.Runtime.Extensions.dll
  • net8.0\MASES.KNetPS.dll
  • jars\jackson-module-jaxb-annotations-2.16.2.jar
  • net462\C2JBridge.dll
  • net462\System.Runtime.Handles.dll
  • net8.0\MASES.KNetPS.exe
  • jars\jackson-module-scala_2.13-2.16.2.jar
  • net462\IpAddressIdGenerator.exe
  • net462\System.Runtime.InteropServices.dll
  • net8.0\MASES.KNetPS.pdb
  • jars\jakarta.activation-api-1.2.2.jar
  • net462\IpAddressIdGenerator.exe.config
  • net462\System.Runtime.InteropServices.RuntimeInformation.dll
  • net8.0\MASES.KNetPS.runtimeconfig.json
  • jars\jakarta.annotation-api-1.3.5.jar
  • net462\J2CBridge_x64.dll
  • net462\System.Runtime.Numerics.dll
  • net8.0\MASES.KNetPSCore.psd1
  • jars\jakarta.inject-2.6.1.jar
  • net462\J2CBridge_x86.dll
  • net462\System.Runtime.Serialization.Formatters.dll
  • net8.0\Microsoft.NET8.App.runtimeconfig.json
  • jars\jakarta.validation-api-2.0.2.jar
  • net462\JCOBridge.docs.jar
  • net462\System.Runtime.Serialization.Json.dll
  • net8.0\Microsoft.WindowsDesktop8.App.runtimeconfig.json
  • jars\jakarta.ws.rs-api-2.1.6.jar
  • net462\JCOBridge.jar
  • net462\System.Runtime.Serialization.Primitives.dll
  • net8.0\System.Management.Automation.dll
  • jars\jakarta.xml.bind-api-2.3.3.jar
  • net462\LicenseManagerUI.exe
  • net462\System.Runtime.Serialization.Xml.dll
  • net8.0\config\connect-console-sink.properties
  • jars\javassist-3.29.2-GA.jar
  • net462\LicenseManagerUI.exe.config
  • net462\System.Security.Claims.dll
  • net8.0\config\connect-console-source.properties
  • jars\javax.activation-api-1.2.0.jar
  • net462\LicenseViewer.exe
  • net462\System.Security.Cryptography.Algorithms.dll
  • net8.0\config\connect-distributed.properties
  • jars\javax.annotation-api-1.3.2.jar
  • net462\LicenseViewer.exe.config
  • net462\System.Security.Cryptography.Csp.dll
  • net8.0\config\connect-file-sink.properties
  • jars\javax.servlet-api-3.1.0.jar
  • net462\MachineIdGenerator.exe
  • net462\System.Security.Cryptography.Encoding.dll
  • net8.0\config\connect-file-source.properties
  • jars\javax.ws.rs-api-2.1.1.jar
  • net462\MachineIdGenerator.exe.config
  • net462\System.Security.Cryptography.Primitives.dll
  • net8.0\config\connect-knet-sink.properties
  • jars\jaxb-api-2.3.1.jar
  • net462\MASES.CLIParser.dll
  • net462\System.Security.Cryptography.X509Certificates.dll
  • net8.0\config\connect-knet-source.properties
  • jars\jersey-client-2.39.1.jar
  • net462\MASES.JNet.dll
  • net462\System.Security.Principal.dll
  • net8.0\config\connect-log4j.properties
  • jars\jersey-common-2.39.1.jar
  • net462\MASES.JNetPSCore.dll
  • net462\System.Security.SecureString.dll
  • net8.0\config\connect-mirror-maker.properties
  • jars\jersey-container-servlet-2.39.1.jar
  • net462\MASES.KNet.dll
  • net462\System.Text.Encoding.dll
  • net8.0\config\connect-standalone.properties
  • jars\jersey-container-servlet-core-2.39.1.jar
  • net462\MASES.KNet.pdb
  • net462\System.Text.Encoding.Extensions.dll
  • net8.0\config\consumer.properties
  • jars\jersey-hk2-2.39.1.jar
  • net462\MASES.KNet.xml
  • net462\System.Text.RegularExpressions.dll
  • net8.0\config\knet-log4j.properties
  • jars\jersey-server-2.39.1.jar
  • net462\MASES.KNetPS.dll
  • net462\System.Threading.dll
  • net8.0\config\log4j.properties
  • jars\jetty-client-9.4.57.v20241219.jar
  • net462\MASES.KNetPS.pdb
  • net462\System.Threading.Overlapped.dll
  • net8.0\config\producer.properties
  • jars\jetty-continuation-9.4.57.v20241219.jar
  • net462\MASES.KNetPSFramework.psd1
  • net462\System.Threading.Tasks.dll
  • net8.0\config\README.md
  • jars\jetty-http-9.4.57.v20241219.jar
  • net462\Microsoft.Bcl.AsyncInterfaces.dll
  • net462\System.Threading.Tasks.Extensions.dll
  • net8.0\config\server.properties
  • jars\jetty-io-9.4.57.v20241219.jar
  • net462\Microsoft.Win32.Primitives.dll
  • net462\System.Threading.Tasks.Parallel.dll
  • net8.0\config\tools-log4j.properties
  • jars\jetty-security-9.4.57.v20241219.jar
  • net462\netstandard.dll
  • net462\System.Threading.Thread.dll
  • net8.0\config\trogdor.conf
  • jars\jetty-server-9.4.57.v20241219.jar
  • net462\System.AppContext.dll
  • net462\System.Threading.ThreadPool.dll
  • net8.0\config\zookeeper.properties
  • jars\jetty-servlet-9.4.57.v20241219.jar
  • net462\System.Collections.Concurrent.dll
  • net462\System.Threading.Timer.dll
  • net8.0\config\kraft\broker.properties
  • jars\jetty-servlets-9.4.57.v20241219.jar
  • net462\System.Collections.dll
  • net462\System.ValueTuple.dll
  • net8.0\config\kraft\controller.properties
  • jars\jetty-util-9.4.57.v20241219.jar
  • net462\System.Collections.NonGeneric.dll
  • net462\System.Xml.ReaderWriter.dll
  • net8.0\config\kraft\README.md
  • jars\jetty-util-ajax-9.4.57.v20241219.jar
  • net462\System.Collections.Specialized.dll
  • net462\System.Xml.XDocument.dll
  • net8.0\config\kraft\server.properties
  • jars\jline-3.25.1.jar
  • net462\System.ComponentModel.dll
  • net462\System.Xml.XmlDocument.dll
  • net8.0\jars\jnet-2.5.12.0.jar
  • jars\jopt-simple-5.0.4.jar
  • net462\System.ComponentModel.EventBasedAsync.dll
  • net462\System.Xml.XmlSerializer.dll
  • net8.0\linux-arm\J2CBridgeHostActivator.so
  • jars\jose4j-0.9.4.jar
  • net462\System.ComponentModel.Primitives.dll
  • net462\System.Xml.XPath.dll
  • net8.0\linux-arm64\J2CBridgeHostActivator.so
  • jars\jsr305-3.0.2.jar
  • net462\System.ComponentModel.TypeConverter.dll
  • net462\System.Xml.XPath.XDocument.dll
  • net8.0\linux-x64\J2CBridgeHostActivator.so
  • jars\kafka-clients-3.9.1.jar
  • net462\System.Console.dll
  • net462\config\connect-console-sink.properties
  • net8.0\osx-arm64\J2CBridgeHostActivator.dylib
  • jars\kafka-group-coordinator-3.9.1.jar
  • net462\System.Data.Common.dll
  • net462\config\connect-console-source.properties
  • net8.0\osx-x64\J2CBridgeHostActivator.dylib
  • jars\kafka-group-coordinator-api-3.9.1.jar
  • net462\System.Diagnostics.Contracts.dll
  • net462\config\connect-distributed.properties
  • net8.0\win-arm64\J2CBridgeHostActivator.dll
  • jars\kafka-metadata-3.9.1.jar
  • net462\System.Diagnostics.Debug.dll
  • net462\config\connect-file-sink.properties
  • net8.0\win-x64\J2CBridgeHostActivator.dll
  • jars\kafka-raft-3.9.1.jar
  • net462\System.Diagnostics.FileVersionInfo.dll
  • net462\config\connect-file-source.properties
  • net8.0\win-x86\J2CBridgeHostActivator.dll
  • jars\kafka-server-3.9.1.jar
  • net462\System.Diagnostics.Process.dll
  • jars\kafka-server-common-3.9.1.jar
  • net462\System.Diagnostics.StackTrace.dll

Version History

Version Downloads Last updated
2.9.2 (current version) 4 7/17/2025
2.9.1 99 2/5/2025
2.9.0 19 12/23/2024
2.8.2 64 11/5/2024
2.8.1 40 9/20/2024
2.8.0 70 8/6/2024
2.7.10 4 11/5/2024
2.7.9 4 9/20/2024
2.7.8 12 7/31/2024
2.7.7 10 7/30/2024
2.7.6 7 7/29/2024
2.7.5 20 7/2/2024
2.7.4 9 6/27/2024
2.6.7 4 11/5/2024
2.6.6 4 9/20/2024
2.6.5 5 9/16/2024
2.6.4 11 6/14/2024
Show more