Table of Contents

Class KEFCore

Namespace
MASES.EntityFrameworkCore.KNet
Assembly
MASES.EntityFrameworkCore.KNet.dll

This is the primary class shall be used to initialize the environment to use Entity Framework Core for Apache Kafka

public class KEFCore : KNetCore<KEFCore>, IJVMWrapperManagement
Inheritance
KEFCore
Implements
Inherited Members
JNetCoreBase<KEFCore>.ApplicationDisableOpenOnJavaNio
JNetCoreBase<KEFCore>.ApplicationEnableNativeAccess
JNetCoreBase<KEFCore>.DisableOpenOnJavaNio
JNetCoreBase<KEFCore>.EnableNativeAccess
SetupJVMWrapper<KEFCore>.ScopedOn
SetupJVMWrapper<KEFCore>.ScopedOnVersion
SetupJVMWrapper.Initialize()
SetupJVMWrapper.InitializeRemote()

Examples

The most simple way to use this class is to execute the following code at the beginning of the application:

KEFCore.CreateGlobalInstance();

The class reads configuration parameters in multiple ways: command line, environment variables and code override. To insert values in the code an user can create a custom class like the following and overrides the interested properties:

public class CustomKEFCore : KEFCore
{
    public override string JVMPath => "MySpecialPath";
}

Properties

PreserveInformationAcrossContexts

Set to false to disable Apache Kafka Streams caching, default is true

public static bool PreserveInformationAcrossContexts { get; set; }

Property Value

bool

Remarks

This value is read only once when application starts: if the backend uses Apache Kafka Streams (i.e. UseCompactedReplicator is false), the value is read to understand how to manage Streams instances lifetime

Methods

DefaultLog4JConfiguration()

Returns the default configuration file to use when initializing command line defaults

protected override string DefaultLog4JConfiguration()

Returns

string

The configuration file to use for logging

Remarks

Overrides in derived classes to give another default file

Edit this page