MASES.KNetConnect 2.9.0

title: Kafka™ Connect SDK of .NET suite for Apache Kafka™ _description: Describes how to use Kafka™ Connect SDK of .NET suite for Apache Kafka™

KNet: KNet Connect SDK

Installation

KNet Connect is available in two different formats:

• dotnet tool hosted on NuGet: check https://www.nuget.org/packages/MASES.KNetConnect/ and https://docs.microsoft.com/en-us/dotnet/core/tools/global-tools for installation deep instructions.
• Docker image hosted on GitHub or Docker Hub: follow instruction within the page and general instruction on https://docs.docker.com

[!IMPORTANT] The dotnet tool needs a JRE/JDK installed within the system

Usage

To use the Connect interface (KNetConnect) runs a command like the following:

• dotnet tool

knetconnect -s connect-standalone.properties specific-connector.properties

knetconnect -d connect-distributed.properties

[!IMPORTANT] If the previous commands raise the error described in Intel CET and KNet the only solution is to apply the following workaround (within an elevated shell) and disable CET:

  reg add "HKEY_LOCAL_MACHINE\SOFTWARE\Microsoft\Windows NT\CurrentVersion\Image File Execution Options\knetconnect.exe" /v MitigationOptions /t REG_BINARY /d "0000000000000000000000000000002000" /f

• Docker image

docker run ghcr.io/masesgroup/knetconnect -s connect-standalone.properties specific-connector.properties

docker run masesgroup/knetconnect -s connect-standalone.properties specific-connector.properties

docker run ghcr.io/masesgroup/knetconnect -d connect-distributed.properties

docker run masesgroup/knetconnect -d connect-distributed.properties

Command line switch available

knetconnect accepts the following command-line switch to identify its behavior:

• d: starts a distributed version of Connector defined in the file identified from the subsequent parameter
• s: starts a standalone version of Connector defined in the file identified from the subsequent parameter
• k: starts a KNet version (Distributed or Standalone) accepting environment variables names containing the data associated to the parameters expected from the stanard version
• other parameters in sequence are:
  • Apache Kafka™ Connect configuration file
  • KNet Connector configuration file
  • or in case of k switch is used the parameters are the environemnt variables containing the configuration data in the following form:
    • key and value separated with =
    • key-value pair separated with ||
    • an example is key1=value1||key2=value2||key3

Connector properties

For an overview of configuration see Connect SDK