Class StreamsConfig

Namespace: Org.Apache.Kafka.Streams

Assembly: MASES.KNet.dll

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html

public class StreamsConfig : AbstractConfig, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition, IJVMBridgeMain

Inheritance: object

DynamicObject

JVMBridgeBase

JVMBridgeBase<AbstractConfig>

AbstractConfig

StreamsConfig

Implements: IDynamicMetaObjectProvider

IJVMBridgeCore

IDisposable

IJVMBridgeBaseStatic

IJVMBridgeBase

IJVMBridgeDefinition

IJVMBridgeMain

Inherited Members: AbstractConfig.AUTOMATIC_CONFIG_PROVIDERS_PROPERTY

AbstractConfig.CONFIG_PROVIDERS_CONFIG

AbstractConfig.GetConfiguredInstances<T>(String, Class, Map<String, object>)

AbstractConfig.GetConfiguredInstances<T>(String, Class)

AbstractConfig.GetConfiguredInstances<T>(List<String>, Class, Map<String, object>)

AbstractConfig.GetConfiguredInstance<T>(String, Class, Map<String, object>)

AbstractConfig.GetConfiguredInstance<T>(String, Class)

AbstractConfig.GetBoolean(String)

AbstractConfig.GetClass(String)

AbstractConfig.GetDouble(String)

AbstractConfig.GetInt(String)

AbstractConfig.GetLong(String)

AbstractConfig.GetShort(String)

AbstractConfig.DocumentationOf(String)

AbstractConfig.GetString(String)

AbstractConfig.GetList(String)

AbstractConfig.NonInternalValues()

AbstractConfig.Values()

AbstractConfig.Originals()

AbstractConfig.Originals(Map<String, object>)

AbstractConfig.OriginalsWithPrefix(String, bool)

AbstractConfig.OriginalsWithPrefix(String)

AbstractConfig.ValuesWithPrefixAllOrNothing(String)

AbstractConfig.ValuesWithPrefixOverride(String)

AbstractConfig.OriginalsStrings()

AbstractConfig.Unused()

AbstractConfig.TypeOf(String)

AbstractConfig.GetPassword(String)

AbstractConfig.Ignore(String)

AbstractConfig.LogUnused()

JVMBridgeBase<AbstractConfig>.SExecute(IJavaType, string, params object[])

JVMBridgeBase<AbstractConfig>.SExecuteWithSignature(IJavaType, string, string, params object[])

JVMBridgeBase<AbstractConfig>.SExecute(string, params object[])

JVMBridgeBase<AbstractConfig>.SExecuteWithSignature(string, string, params object[])

JVMBridgeBase<AbstractConfig>.SExecute<TReturn>(IJavaType, string, params object[])

JVMBridgeBase<AbstractConfig>.SExecuteWithSignature<TReturn>(IJavaType, string, string, params object[])

JVMBridgeBase<AbstractConfig>.SExecute<TReturn>(string, params object[])

JVMBridgeBase<AbstractConfig>.SExecuteWithSignature<TReturn>(string, string, params object[])

JVMBridgeBase<AbstractConfig>.SExecute(Type, IJavaType, string, params object[])

JVMBridgeBase<AbstractConfig>.SExecuteWithSignature(Type, IJavaType, string, string, params object[])

JVMBridgeBase<AbstractConfig>.SExecute(Type, string, params object[])

JVMBridgeBase<AbstractConfig>.SExecuteWithSignature(Type, string, string, params object[])

JVMBridgeBase<AbstractConfig>.SExecute<TNewClass, TReturn>(IJavaType, string, params object[])

JVMBridgeBase<AbstractConfig>.SExecuteWithSignature<TNewClass, TReturn>(IJavaType, string, string, params object[])

JVMBridgeBase<AbstractConfig>.SExecute<TNewClass, TReturn>(string, params object[])

JVMBridgeBase<AbstractConfig>.SExecuteWithSignature<TNewClass, TReturn>(string, string, params object[])

JVMBridgeBase<AbstractConfig>.SExecute<TReturn>(Type, IJavaType, string, params object[])

JVMBridgeBase<AbstractConfig>.SExecuteWithSignature<TReturn>(Type, IJavaType, string, string, params object[])

JVMBridgeBase<AbstractConfig>.SExecute<TReturn>(Type, string, params object[])

JVMBridgeBase<AbstractConfig>.SExecuteWithSignature<TReturn>(Type, string, string, params object[])

JVMBridgeBase<AbstractConfig>.SExecute<TNewClass, TReturn, TConverter>(IJavaType, string, params object[])

JVMBridgeBase<AbstractConfig>.SExecuteWithSignature<TNewClass, TReturn, TConverter>(IJavaType, string, string, params object[])

JVMBridgeBase<AbstractConfig>.SExecute<TNewClass, TReturn, TConverter>(string, params object[])

JVMBridgeBase<AbstractConfig>.SExecuteWithSignature<TNewClass, TReturn, TConverter>(string, string, params object[])

JVMBridgeBase<AbstractConfig>.SExecute<TReturn, TConverter>(Type, IJavaType, string, params object[])

JVMBridgeBase<AbstractConfig>.SExecuteWithSignature<TReturn, TConverter>(Type, IJavaType, string, string, params object[])

JVMBridgeBase<AbstractConfig>.SExecute<TReturn, TConverter>(Type, string, params object[])

JVMBridgeBase<AbstractConfig>.SExecuteWithSignature<TReturn, TConverter>(Type, string, string, params object[])

JVMBridgeBase<AbstractConfig>.SExecuteArray<T>(IJavaType, string, params object[])

JVMBridgeBase<AbstractConfig>.SExecuteWithSignatureArray<T>(IJavaType, string, string, params object[])

JVMBridgeBase<AbstractConfig>.SExecuteArray<T>(string, params object[])

JVMBridgeBase<AbstractConfig>.SExecuteWithSignatureArray<T>(string, string, params object[])

JVMBridgeBase<AbstractConfig>.SGetField(IJavaType, string)

JVMBridgeBase<AbstractConfig>.SGetField(string)

JVMBridgeBase<AbstractConfig>.SGetField<TReturn>(IJavaType, string)

JVMBridgeBase<AbstractConfig>.SGetField<TReturn>(string)

JVMBridgeBase<AbstractConfig>.SGetFieldArray<TReturn>(IJavaType, string)

JVMBridgeBase<AbstractConfig>.SGetFieldArray<TReturn>(string)

JVMBridgeBase<AbstractConfig>.SSetField(IJavaType, string, object)

JVMBridgeBase<AbstractConfig>.SSetField(string, object)

JVMBridgeBase<AbstractConfig>.SSetField<TValue>(IJavaType, string, TValue)

JVMBridgeBase<AbstractConfig>.SSetField<TValue>(string, TValue)

JVMBridgeBase<AbstractConfig>.IsAssignableFrom(string)

JVMBridgeBase<AbstractConfig>.IsAssignableFrom(IJavaType)

JVMBridgeBase<AbstractConfig>.IsAssignableFrom<T>()

JVMBridgeBase<AbstractConfig>.New(params object[])

JVMBridgeBase<AbstractConfig>.NewWithSignature(string, params object[])

JVMBridgeBase<AbstractConfig>.Execute<T>(params T[])

JVMBridgeBase<AbstractConfig>.DynBridgeClazz

JVMBridgeBase<AbstractConfig>.BridgeClazz

JVMBridgeBase.ClazzOf<TClass>(bool)

JVMBridgeBase.ClazzOf(string, bool)

JVMBridgeBase.RuntimeClassNameOf<T>()

JVMBridgeBase.ClassNameOf<T>()

JVMBridgeBase.ClassOf<T>()

JVMBridgeBase.WrapsDirect<TNewClass>(IJavaObject)

JVMBridgeBase.Wraps<TNewClass>(IJavaObject)

JVMBridgeBase.Wraps(Type, IJavaObject, string)

JVMBridgeBase.Wraps<TNewClass, TReturn>(IJavaObject)

JVMBridgeBase.Wraps<TReturn>(Type, IJavaObject, string)

JVMBridgeBase.Wraps<TNewClass, TReturn, TConverter>(IJavaObject)

JVMBridgeBase.Wraps<TReturn, TConverter>(Type, IJavaObject)

JVMBridgeBase.MonitorEnter()

JVMBridgeBase.MonitorExit()

JVMBridgeBase.IsInstanceOf(string)

JVMBridgeBase.IsInstanceOf(IJavaType)

JVMBridgeBase.IsInstanceOf<T>()

JVMBridgeBase.RuntimeIsInstanceOf<T>()

JVMBridgeBase.CastTo<TNewClass>()

JVMBridgeBase.CastDirect<TNewClass>()

JVMBridgeBase.Dispose()

JVMBridgeBase.ToString()

JVMBridgeBase.Equals(object)

JVMBridgeBase.GetHashCode()

JVMBridgeBase.Notify()

JVMBridgeBase.NotifyAll()

JVMBridgeBase.Wait()

JVMBridgeBase.Wait(long)

JVMBridgeBase.Wait(long, int)

JVMBridgeBase.IExecute(string, params object[])

JVMBridgeBase.IExecuteWithSignature(string, string, params object[])

JVMBridgeBase.IExecute<TReturn>(string, params object[])

JVMBridgeBase.IExecuteWithSignature<TReturn>(string, string, params object[])

JVMBridgeBase.IExecute<TNewClass, TReturn>(string, params object[])

JVMBridgeBase.IExecuteWithSignature<TNewClass, TReturn>(string, string, params object[])

JVMBridgeBase.IExecute<TNewClass, TReturn, TConverter>(string, params object[])

JVMBridgeBase.IExecuteWithSignature<TNewClass, TReturn, TConverter>(string, string, params object[])

JVMBridgeBase.IExecuteArray<T>(string, params object[])

JVMBridgeBase.IExecuteWithSignatureArray<T>(string, string, params object[])

JVMBridgeBase.IGetField(string)

JVMBridgeBase.IGetField<TReturn>(string)

JVMBridgeBase.IGetFieldArray<TReturn>(string)

JVMBridgeBase.ISetField(string, object)

JVMBridgeBase.ISetField<TValue>(string, TValue)

JVMBridgeBase.DynBridgeInstance

JVMBridgeBase.BridgeInstance

JVMBridgeBase.IsBridgeListener

DynamicObject.TryGetMember(GetMemberBinder, out object)

DynamicObject.TrySetMember(SetMemberBinder, object)

DynamicObject.TryDeleteMember(DeleteMemberBinder)

DynamicObject.TryInvokeMember(InvokeMemberBinder, object[], out object)

DynamicObject.TryConvert(ConvertBinder, out object)

DynamicObject.TryCreateInstance(CreateInstanceBinder, object[], out object)

DynamicObject.TryInvoke(InvokeBinder, object[], out object)

DynamicObject.TryBinaryOperation(BinaryOperationBinder, object, out object)

DynamicObject.TryUnaryOperation(UnaryOperationBinder, out object)

DynamicObject.TryGetIndex(GetIndexBinder, object[], out object)

DynamicObject.TrySetIndex(SetIndexBinder, object[], object)

DynamicObject.TryDeleteIndex(DeleteIndexBinder, object[])

DynamicObject.GetDynamicMemberNames()

DynamicObject.GetMetaObject(Expression)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetType()

object.MemberwiseClone()

Constructors

StreamsConfig()

Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge

public StreamsConfig()

StreamsConfig(Map<object, object>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#org.apache.kafka.streams.StreamsConfig(java.util.Map)

public StreamsConfig(Map<object, object> arg0)

Parameters

arg0 Map<object, object>: Map

StreamsConfig(params object[])

Generic constructor: it is useful for JCOBridge when there is a derived class which needs to pass arguments to the highest JVMBridgeBase class

public StreamsConfig(params object[] args)

Parameters

args object[]

Properties

ACCEPTABLE_RECOVERY_LAG_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#ACCEPTABLE_RECOVERY_LAG_CONFIG

public static String ACCEPTABLE_RECOVERY_LAG_CONFIG { get; }

Property Value

String

ADMIN_CLIENT_PREFIX

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#ADMIN_CLIENT_PREFIX

public static String ADMIN_CLIENT_PREFIX { get; }

Property Value

String

APPLICATION_ID_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#APPLICATION_ID_CONFIG

public static String APPLICATION_ID_CONFIG { get; }

Property Value

String

APPLICATION_SERVER_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#APPLICATION_SERVER_CONFIG

public static String APPLICATION_SERVER_CONFIG { get; }

Property Value

String

AT_LEAST_ONCE

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#AT_LEAST_ONCE

public static String AT_LEAST_ONCE { get; }

Property Value

String

BOOTSTRAP_SERVERS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#BOOTSTRAP_SERVERS_CONFIG

public static String BOOTSTRAP_SERVERS_CONFIG { get; }

Property Value

String

BUFFERED_RECORDS_PER_PARTITION_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#BUFFERED_RECORDS_PER_PARTITION_CONFIG

public static String BUFFERED_RECORDS_PER_PARTITION_CONFIG { get; }

Property Value

String

BUFFERED_RECORDS_PER_PARTITION_DOC

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#BUFFERED_RECORDS_PER_PARTITION_DOC

public static String BUFFERED_RECORDS_PER_PARTITION_DOC { get; }

Property Value

String

BUILT_IN_METRICS_VERSION_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#BUILT_IN_METRICS_VERSION_CONFIG

public static String BUILT_IN_METRICS_VERSION_CONFIG { get; }

Property Value

String

BridgeClassName

https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeBase_BridgeClassName.htm

public override string BridgeClassName { get; }

Property Value

string

CACHE_MAX_BYTES_BUFFERING_DOC

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#CACHE_MAX_BYTES_BUFFERING_DOC

public static String CACHE_MAX_BYTES_BUFFERING_DOC { get; }

Property Value

String

CLIENT_ID_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#CLIENT_ID_CONFIG

public static String CLIENT_ID_CONFIG { get; }

Property Value

String

CLIENT_TAG_PREFIX

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#CLIENT_TAG_PREFIX

public static String CLIENT_TAG_PREFIX { get; }

Property Value

String

COMMIT_INTERVAL_MS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#COMMIT_INTERVAL_MS_CONFIG

public static String COMMIT_INTERVAL_MS_CONFIG { get; }

Property Value

String

CONNECTIONS_MAX_IDLE_MS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#CONNECTIONS_MAX_IDLE_MS_CONFIG

public static String CONNECTIONS_MAX_IDLE_MS_CONFIG { get; }

Property Value

String

CONSUMER_PREFIX

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#CONSUMER_PREFIX

public static String CONSUMER_PREFIX { get; }

Property Value

String

ClientTags

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#getClientTags--

public Map<String, String> ClientTags { get; }

Property Value

Map<String, String>

DEFAULT_CLIENT_SUPPLIER_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#DEFAULT_CLIENT_SUPPLIER_CONFIG

public static String DEFAULT_CLIENT_SUPPLIER_CONFIG { get; }

Property Value

String

DEFAULT_CLIENT_SUPPLIER_DOC

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#DEFAULT_CLIENT_SUPPLIER_DOC

public static String DEFAULT_CLIENT_SUPPLIER_DOC { get; }

Property Value

String

DEFAULT_DESERIALIZATION_EXCEPTION_HANDLER_CLASS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#DEFAULT_DESERIALIZATION_EXCEPTION_HANDLER_CLASS_CONFIG

public static String DEFAULT_DESERIALIZATION_EXCEPTION_HANDLER_CLASS_CONFIG { get; }

Property Value

String

DEFAULT_DESERIALIZATION_EXCEPTION_HANDLER_CLASS_DOC

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#DEFAULT_DESERIALIZATION_EXCEPTION_HANDLER_CLASS_DOC

public static String DEFAULT_DESERIALIZATION_EXCEPTION_HANDLER_CLASS_DOC { get; }

Property Value

String

DEFAULT_KEY_SERDE_CLASS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#DEFAULT_KEY_SERDE_CLASS_CONFIG

public static String DEFAULT_KEY_SERDE_CLASS_CONFIG { get; }

Property Value

String

DEFAULT_PRODUCTION_EXCEPTION_HANDLER_CLASS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#DEFAULT_PRODUCTION_EXCEPTION_HANDLER_CLASS_CONFIG

public static String DEFAULT_PRODUCTION_EXCEPTION_HANDLER_CLASS_CONFIG { get; }

Property Value

String

DEFAULT_TIMESTAMP_EXTRACTOR_CLASS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#DEFAULT_TIMESTAMP_EXTRACTOR_CLASS_CONFIG

public static String DEFAULT_TIMESTAMP_EXTRACTOR_CLASS_CONFIG { get; }

Property Value

String

DEFAULT_TIMESTAMP_EXTRACTOR_CLASS_DOC

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#DEFAULT_TIMESTAMP_EXTRACTOR_CLASS_DOC

public static String DEFAULT_TIMESTAMP_EXTRACTOR_CLASS_DOC { get; }

Property Value

String

DEFAULT_VALUE_SERDE_CLASS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#DEFAULT_VALUE_SERDE_CLASS_CONFIG

public static String DEFAULT_VALUE_SERDE_CLASS_CONFIG { get; }

Property Value

String

DSL_STORE_SUPPLIERS_CLASS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#DSL_STORE_SUPPLIERS_CLASS_CONFIG

public static String DSL_STORE_SUPPLIERS_CLASS_CONFIG { get; }

Property Value

String

DUMMY_THREAD_INDEX

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#DUMMY_THREAD_INDEX

public static int DUMMY_THREAD_INDEX { get; }

Property Value

int

ENABLE_METRICS_PUSH_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#ENABLE_METRICS_PUSH_CONFIG

public static String ENABLE_METRICS_PUSH_CONFIG { get; }

Property Value

String

ENABLE_METRICS_PUSH_DOC

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#ENABLE_METRICS_PUSH_DOC

public static String ENABLE_METRICS_PUSH_DOC { get; }

Property Value

String

EXACTLY_ONCE_V2

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#EXACTLY_ONCE_V2

public static String EXACTLY_ONCE_V2 { get; }

Property Value

String

GLOBAL_CONSUMER_PREFIX

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#GLOBAL_CONSUMER_PREFIX

public static String GLOBAL_CONSUMER_PREFIX { get; }

Property Value

String

IsBridgeAbstract

https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeBase_IsBridgeAbstract.htm

public override bool IsBridgeAbstract { get; }

Property Value

bool

IsBridgeCloseable

https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeBase_IsBridgeCloseable.htm

public override bool IsBridgeCloseable { get; }

Property Value

bool

IsBridgeInterface

https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeBase_IsBridgeInterface.htm

public override bool IsBridgeInterface { get; }

Property Value

bool

IsBridgeStatic

https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeBase_IsBridgeStatic.htm

public override bool IsBridgeStatic { get; }

Property Value

bool

KafkaClientSupplier

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#getKafkaClientSupplier--

public KafkaClientSupplier KafkaClientSupplier { get; }

Property Value

KafkaClientSupplier

LOG_SUMMARY_INTERVAL_MS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#LOG_SUMMARY_INTERVAL_MS_CONFIG

public static String LOG_SUMMARY_INTERVAL_MS_CONFIG { get; }

Property Value

String

MAIN_CONSUMER_PREFIX

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#MAIN_CONSUMER_PREFIX

public static String MAIN_CONSUMER_PREFIX { get; }

Property Value

String

MAX_RACK_AWARE_ASSIGNMENT_TAG_KEY_LENGTH

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#MAX_RACK_AWARE_ASSIGNMENT_TAG_KEY_LENGTH

public static int MAX_RACK_AWARE_ASSIGNMENT_TAG_KEY_LENGTH { get; }

Property Value

int

MAX_RACK_AWARE_ASSIGNMENT_TAG_LIST_SIZE

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#MAX_RACK_AWARE_ASSIGNMENT_TAG_LIST_SIZE

public static int MAX_RACK_AWARE_ASSIGNMENT_TAG_LIST_SIZE { get; }

Property Value

int

MAX_RACK_AWARE_ASSIGNMENT_TAG_VALUE_LENGTH

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#MAX_RACK_AWARE_ASSIGNMENT_TAG_VALUE_LENGTH

public static int MAX_RACK_AWARE_ASSIGNMENT_TAG_VALUE_LENGTH { get; }

Property Value

int

MAX_TASK_IDLE_MS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#MAX_TASK_IDLE_MS_CONFIG

public static String MAX_TASK_IDLE_MS_CONFIG { get; }

Property Value

String

MAX_TASK_IDLE_MS_DISABLED

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#MAX_TASK_IDLE_MS_DISABLED

public static long MAX_TASK_IDLE_MS_DISABLED { get; }

Property Value

long

MAX_TASK_IDLE_MS_DOC

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#MAX_TASK_IDLE_MS_DOC

public static String MAX_TASK_IDLE_MS_DOC { get; }

Property Value

String

MAX_WARMUP_REPLICAS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#MAX_WARMUP_REPLICAS_CONFIG

public static String MAX_WARMUP_REPLICAS_CONFIG { get; }

Property Value

String

MERGE_REPARTITION_TOPICS

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#MERGE_REPARTITION_TOPICS

public static String MERGE_REPARTITION_TOPICS { get; }

Property Value

String

METADATA_MAX_AGE_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#METADATA_MAX_AGE_CONFIG

public static String METADATA_MAX_AGE_CONFIG { get; }

Property Value

String

METRICS_LATEST

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#METRICS_LATEST

public static String METRICS_LATEST { get; }

Property Value

String

METRICS_NUM_SAMPLES_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#METRICS_NUM_SAMPLES_CONFIG

public static String METRICS_NUM_SAMPLES_CONFIG { get; }

Property Value

String

METRICS_RECORDING_LEVEL_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#METRICS_RECORDING_LEVEL_CONFIG

public static String METRICS_RECORDING_LEVEL_CONFIG { get; }

Property Value

String

METRICS_SAMPLE_WINDOW_MS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#METRICS_SAMPLE_WINDOW_MS_CONFIG

public static String METRICS_SAMPLE_WINDOW_MS_CONFIG { get; }

Property Value

String

METRIC_REPORTER_CLASSES_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#METRIC_REPORTER_CLASSES_CONFIG

public static String METRIC_REPORTER_CLASSES_CONFIG { get; }

Property Value

String

NO_OPTIMIZATION

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#NO_OPTIMIZATION

public static String NO_OPTIMIZATION { get; }

Property Value

String

NUM_STANDBY_REPLICAS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#NUM_STANDBY_REPLICAS_CONFIG

public static String NUM_STANDBY_REPLICAS_CONFIG { get; }

Property Value

String

NUM_STREAM_THREADS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#NUM_STREAM_THREADS_CONFIG

public static String NUM_STREAM_THREADS_CONFIG { get; }

Property Value

String

OPTIMIZE

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#OPTIMIZE

public static String OPTIMIZE { get; }

Property Value

String

POLL_MS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#POLL_MS_CONFIG

public static String POLL_MS_CONFIG { get; }

Property Value

String

PROBING_REBALANCE_INTERVAL_MS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#PROBING_REBALANCE_INTERVAL_MS_CONFIG

public static String PROBING_REBALANCE_INTERVAL_MS_CONFIG { get; }

Property Value

String

PROCESSING_EXCEPTION_HANDLER_CLASS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#PROCESSING_EXCEPTION_HANDLER_CLASS_CONFIG

public static String PROCESSING_EXCEPTION_HANDLER_CLASS_CONFIG { get; }

Property Value

String

PROCESSING_EXCEPTION_HANDLER_CLASS_DOC

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#PROCESSING_EXCEPTION_HANDLER_CLASS_DOC

public static String PROCESSING_EXCEPTION_HANDLER_CLASS_DOC { get; }

Property Value

String

PROCESSING_GUARANTEE_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#PROCESSING_GUARANTEE_CONFIG

public static String PROCESSING_GUARANTEE_CONFIG { get; }

Property Value

String

PRODUCER_PREFIX

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#PRODUCER_PREFIX

public static String PRODUCER_PREFIX { get; }

Property Value

String

RACK_AWARE_ASSIGNMENT_NON_OVERLAP_COST_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#RACK_AWARE_ASSIGNMENT_NON_OVERLAP_COST_CONFIG

public static String RACK_AWARE_ASSIGNMENT_NON_OVERLAP_COST_CONFIG { get; }

Property Value

String

RACK_AWARE_ASSIGNMENT_NON_OVERLAP_COST_DOC

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#RACK_AWARE_ASSIGNMENT_NON_OVERLAP_COST_DOC

public static String RACK_AWARE_ASSIGNMENT_NON_OVERLAP_COST_DOC { get; }

Property Value

String

RACK_AWARE_ASSIGNMENT_STRATEGY_BALANCE_SUBTOPOLOGY

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#RACK_AWARE_ASSIGNMENT_STRATEGY_BALANCE_SUBTOPOLOGY

public static String RACK_AWARE_ASSIGNMENT_STRATEGY_BALANCE_SUBTOPOLOGY { get; }

Property Value

String

RACK_AWARE_ASSIGNMENT_STRATEGY_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#RACK_AWARE_ASSIGNMENT_STRATEGY_CONFIG

public static String RACK_AWARE_ASSIGNMENT_STRATEGY_CONFIG { get; }

Property Value

String

RACK_AWARE_ASSIGNMENT_STRATEGY_DOC

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#RACK_AWARE_ASSIGNMENT_STRATEGY_DOC

public static String RACK_AWARE_ASSIGNMENT_STRATEGY_DOC { get; }

Property Value

String

RACK_AWARE_ASSIGNMENT_STRATEGY_MIN_TRAFFIC

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#RACK_AWARE_ASSIGNMENT_STRATEGY_MIN_TRAFFIC

public static String RACK_AWARE_ASSIGNMENT_STRATEGY_MIN_TRAFFIC { get; }

Property Value

String

RACK_AWARE_ASSIGNMENT_STRATEGY_NONE

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#RACK_AWARE_ASSIGNMENT_STRATEGY_NONE

public static String RACK_AWARE_ASSIGNMENT_STRATEGY_NONE { get; }

Property Value

String

RACK_AWARE_ASSIGNMENT_TAGS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#RACK_AWARE_ASSIGNMENT_TAGS_CONFIG

public static String RACK_AWARE_ASSIGNMENT_TAGS_CONFIG { get; }

Property Value

String

RACK_AWARE_ASSIGNMENT_TRAFFIC_COST_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#RACK_AWARE_ASSIGNMENT_TRAFFIC_COST_CONFIG

public static String RACK_AWARE_ASSIGNMENT_TRAFFIC_COST_CONFIG { get; }

Property Value

String

RACK_AWARE_ASSIGNMENT_TRAFFIC_COST_DOC

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#RACK_AWARE_ASSIGNMENT_TRAFFIC_COST_DOC

public static String RACK_AWARE_ASSIGNMENT_TRAFFIC_COST_DOC { get; }

Property Value

String

RECEIVE_BUFFER_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#RECEIVE_BUFFER_CONFIG

public static String RECEIVE_BUFFER_CONFIG { get; }

Property Value

String

RECONNECT_BACKOFF_MAX_MS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#RECONNECT_BACKOFF_MAX_MS_CONFIG

public static String RECONNECT_BACKOFF_MAX_MS_CONFIG { get; }

Property Value

String

RECONNECT_BACKOFF_MS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#RECONNECT_BACKOFF_MS_CONFIG

public static String RECONNECT_BACKOFF_MS_CONFIG { get; }

Property Value

String

REPARTITION_PURGE_INTERVAL_MS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#REPARTITION_PURGE_INTERVAL_MS_CONFIG

public static String REPARTITION_PURGE_INTERVAL_MS_CONFIG { get; }

Property Value

String

REPLICATION_FACTOR_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#REPLICATION_FACTOR_CONFIG

public static String REPLICATION_FACTOR_CONFIG { get; }

Property Value

String

REQUEST_TIMEOUT_MS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#REQUEST_TIMEOUT_MS_CONFIG

public static String REQUEST_TIMEOUT_MS_CONFIG { get; }

Property Value

String

RESTORE_CONSUMER_PREFIX

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#RESTORE_CONSUMER_PREFIX

public static String RESTORE_CONSUMER_PREFIX { get; }

Property Value

String

RETRY_BACKOFF_MS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#RETRY_BACKOFF_MS_CONFIG

public static String RETRY_BACKOFF_MS_CONFIG { get; }

Property Value

String

REUSE_KTABLE_SOURCE_TOPICS

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#REUSE_KTABLE_SOURCE_TOPICS

public static String REUSE_KTABLE_SOURCE_TOPICS { get; }

Property Value

String

ROCKSDB_CONFIG_SETTER_CLASS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#ROCKSDB_CONFIG_SETTER_CLASS_CONFIG

public static String ROCKSDB_CONFIG_SETTER_CLASS_CONFIG { get; }

Property Value

String

SECURITY_PROTOCOL_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#SECURITY_PROTOCOL_CONFIG

public static String SECURITY_PROTOCOL_CONFIG { get; }

Property Value

String

SEND_BUFFER_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#SEND_BUFFER_CONFIG

public static String SEND_BUFFER_CONFIG { get; }

Property Value

String

SINGLE_STORE_SELF_JOIN

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#SINGLE_STORE_SELF_JOIN

public static String SINGLE_STORE_SELF_JOIN { get; }

Property Value

String

STATESTORE_CACHE_MAX_BYTES_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#STATESTORE_CACHE_MAX_BYTES_CONFIG

public static String STATESTORE_CACHE_MAX_BYTES_CONFIG { get; }

Property Value

String

STATESTORE_CACHE_MAX_BYTES_DOC

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#STATESTORE_CACHE_MAX_BYTES_DOC

public static String STATESTORE_CACHE_MAX_BYTES_DOC { get; }

Property Value

String

STATE_CLEANUP_DELAY_MS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#STATE_CLEANUP_DELAY_MS_CONFIG

public static String STATE_CLEANUP_DELAY_MS_CONFIG { get; }

Property Value

String

STATE_DIR_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#STATE_DIR_CONFIG

public static String STATE_DIR_CONFIG { get; }

Property Value

String

TASK_ASSIGNOR_CLASS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#TASK_ASSIGNOR_CLASS_CONFIG

public static String TASK_ASSIGNOR_CLASS_CONFIG { get; }

Property Value

String

TASK_TIMEOUT_MS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#TASK_TIMEOUT_MS_CONFIG

public static String TASK_TIMEOUT_MS_CONFIG { get; }

Property Value

String

TASK_TIMEOUT_MS_DOC

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#TASK_TIMEOUT_MS_DOC

public static String TASK_TIMEOUT_MS_DOC { get; }

Property Value

String

TOPIC_PREFIX

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#TOPIC_PREFIX

public static String TOPIC_PREFIX { get; }

Property Value

String

TOPOLOGY_OPTIMIZATION_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#TOPOLOGY_OPTIMIZATION_CONFIG

public static String TOPOLOGY_OPTIMIZATION_CONFIG { get; }

Property Value

String

UPGRADE_FROM_0100

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#UPGRADE_FROM_0100

public static String UPGRADE_FROM_0100 { get; }

Property Value

String

UPGRADE_FROM_0101

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#UPGRADE_FROM_0101

public static String UPGRADE_FROM_0101 { get; }

Property Value

String

UPGRADE_FROM_0102

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#UPGRADE_FROM_0102

public static String UPGRADE_FROM_0102 { get; }

Property Value

String

UPGRADE_FROM_0110

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#UPGRADE_FROM_0110

public static String UPGRADE_FROM_0110 { get; }

Property Value

String

UPGRADE_FROM_10

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#UPGRADE_FROM_10

public static String UPGRADE_FROM_10 { get; }

Property Value

String

UPGRADE_FROM_11

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#UPGRADE_FROM_11

public static String UPGRADE_FROM_11 { get; }

Property Value

String

UPGRADE_FROM_20

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#UPGRADE_FROM_20

public static String UPGRADE_FROM_20 { get; }

Property Value

String

UPGRADE_FROM_21

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#UPGRADE_FROM_21

public static String UPGRADE_FROM_21 { get; }

Property Value

String

UPGRADE_FROM_22

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#UPGRADE_FROM_22

public static String UPGRADE_FROM_22 { get; }

Property Value

String

UPGRADE_FROM_23

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#UPGRADE_FROM_23

public static String UPGRADE_FROM_23 { get; }

Property Value

String

UPGRADE_FROM_24

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#UPGRADE_FROM_24

public static String UPGRADE_FROM_24 { get; }

Property Value

String

UPGRADE_FROM_25

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#UPGRADE_FROM_25

public static String UPGRADE_FROM_25 { get; }

Property Value

String

UPGRADE_FROM_26

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#UPGRADE_FROM_26

public static String UPGRADE_FROM_26 { get; }

Property Value

String

UPGRADE_FROM_27

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#UPGRADE_FROM_27

public static String UPGRADE_FROM_27 { get; }

Property Value

String

UPGRADE_FROM_28

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#UPGRADE_FROM_28

public static String UPGRADE_FROM_28 { get; }

Property Value

String

UPGRADE_FROM_30

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#UPGRADE_FROM_30

public static String UPGRADE_FROM_30 { get; }

Property Value

String

UPGRADE_FROM_31

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#UPGRADE_FROM_31

public static String UPGRADE_FROM_31 { get; }

Property Value

String

UPGRADE_FROM_32

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#UPGRADE_FROM_32

public static String UPGRADE_FROM_32 { get; }

Property Value

String

UPGRADE_FROM_33

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#UPGRADE_FROM_33

public static String UPGRADE_FROM_33 { get; }

Property Value

String

UPGRADE_FROM_34

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#UPGRADE_FROM_34

public static String UPGRADE_FROM_34 { get; }

Property Value

String

UPGRADE_FROM_35

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#UPGRADE_FROM_35

public static String UPGRADE_FROM_35 { get; }

Property Value

String

UPGRADE_FROM_36

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#UPGRADE_FROM_36

public static String UPGRADE_FROM_36 { get; }

Property Value

String

UPGRADE_FROM_37

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#UPGRADE_FROM_37

public static String UPGRADE_FROM_37 { get; }

Property Value

String

UPGRADE_FROM_38

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#UPGRADE_FROM_38

public static String UPGRADE_FROM_38 { get; }

Property Value

String

UPGRADE_FROM_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#UPGRADE_FROM_CONFIG

public static String UPGRADE_FROM_CONFIG { get; }

Property Value

String

WINDOWED_INNER_CLASS_SERDE

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#WINDOWED_INNER_CLASS_SERDE

public static String WINDOWED_INNER_CLASS_SERDE { get; }

Property Value

String

WINDOW_SIZE_MS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#WINDOW_SIZE_MS_CONFIG

public static String WINDOW_SIZE_MS_CONFIG { get; }

Property Value

String

WINDOW_STORE_CHANGE_LOG_ADDITIONAL_RETENTION_MS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#WINDOW_STORE_CHANGE_LOG_ADDITIONAL_RETENTION_MS_CONFIG

public static String WINDOW_STORE_CHANGE_LOG_ADDITIONAL_RETENTION_MS_CONFIG { get; }

Property Value

String

Methods

AdminClientPrefix(String)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#adminClientPrefix-java.lang.String-

public static String AdminClientPrefix(String arg0)

public static String ClientTagPrefix(String arg0)

Parameters

arg0 String: String

Returns

String: String

ConfigDef()

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#configDef--

public static ConfigDef ConfigDef()

Returns

ConfigDef: ConfigDef

ConsumerPrefix(String)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#consumerPrefix-java.lang.String-

public static String ConsumerPrefix(String arg0)

Parameters

arg0 String: String

Returns

String: String

DefaultDeserializationExceptionHandler()

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#defaultDeserializationExceptionHandler--

public DeserializationExceptionHandler DefaultDeserializationExceptionHandler()

Returns

DeserializationExceptionHandler: DeserializationExceptionHandler

DefaultKeySerde()

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#defaultKeySerde--

public Serde<object> DefaultKeySerde()

Returns

Serde<object>: Serde

DefaultKeySerdeDirect()

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#defaultKeySerde--

public Serde<object> DefaultKeySerdeDirect()

Returns

Serde<object>: Serde

DefaultProductionExceptionHandler()

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#defaultProductionExceptionHandler--

public ProductionExceptionHandler DefaultProductionExceptionHandler()

Returns

ProductionExceptionHandler: ProductionExceptionHandler

DefaultTimestampExtractor()

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#defaultTimestampExtractor--

public TimestampExtractor DefaultTimestampExtractor()

Returns

TimestampExtractor: TimestampExtractor

DefaultTimestampExtractorDirect()

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#defaultTimestampExtractor--

public TimestampExtractor DefaultTimestampExtractorDirect()

Returns

TimestampExtractor: TimestampExtractor

DefaultValueSerde()

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#defaultValueSerde--

public Serde<object> DefaultValueSerde()

Returns

Serde<object>: Serde

DefaultValueSerdeDirect()

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#defaultValueSerde--

public Serde<object> DefaultValueSerdeDirect()

Returns

Serde<object>: Serde

GetAdminConfigs(String)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#getAdminConfigs-java.lang.String-

public Map<String, object> GetAdminConfigs(String arg0)

Parameters

arg0 String: String

Returns

Map<String, object>: Map

GetGlobalConsumerConfigs(String)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#getGlobalConsumerConfigs-java.lang.String-

public Map<String, object> GetGlobalConsumerConfigs(String arg0)

Parameters

arg0 String: String

Returns

Map<String, object>: Map

GetMainConsumerConfigs(String, String, int)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#getMainConsumerConfigs-java.lang.String-java.lang.String-int-

public Map<String, object> GetMainConsumerConfigs(String arg0, String arg1, int arg2)

Parameters

arg0 String: String
arg1 String: String
arg2 int: int

Returns

Map<String, object>: Map

GetProducerConfigs(String)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#getProducerConfigs-java.lang.String-

public Map<String, object> GetProducerConfigs(String arg0)

Parameters

arg0 String: String

Returns

Map<String, object>: Map

GetRestoreConsumerConfigs(String)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#getRestoreConsumerConfigs-java.lang.String-

public Map<String, object> GetRestoreConsumerConfigs(String arg0)

Parameters

arg0 String: String

Returns

Map<String, object>: Map

GlobalConsumerPrefix(String)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#globalConsumerPrefix-java.lang.String-

public static String GlobalConsumerPrefix(String arg0)

Parameters

arg0 String: String

Returns

String: String

Main(String[])

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#main-java.lang.String[]-

public static void Main(String[] arg0)

Parameters

arg0 String[]: String

MainConsumerPrefix(String)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#mainConsumerPrefix-java.lang.String-

public static String MainConsumerPrefix(String arg0)

Parameters

arg0 String: String

Returns

String: String

ProcessingExceptionHandler()

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#processingExceptionHandler--

public ProcessingExceptionHandler ProcessingExceptionHandler()

Returns

ProcessingExceptionHandler: ProcessingExceptionHandler

ProducerPrefix(String)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#producerPrefix-java.lang.String-

public static String ProducerPrefix(String arg0)

Parameters

arg0 String: String

Returns

String: String

RestoreConsumerPrefix(String)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#restoreConsumerPrefix-java.lang.String-

public static String RestoreConsumerPrefix(String arg0)

Parameters

arg0 String: String

Returns

String: String

TopicPrefix(String)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#topicPrefix-java.lang.String-

public static String TopicPrefix(String arg0)

Parameters

arg0 String: String

Returns

String: String

VerifyTopologyOptimizationConfigs(String)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html#verifyTopologyOptimizationConfigs-java.lang.String-

public static Set<String> VerifyTopologyOptimizationConfigs(String arg0)

Parameters

arg0 String: String

Returns

Set<String>: Set

Table of Contents

Class StreamsConfig

Constructors

StreamsConfig()

StreamsConfig(Map<object, object>)

Parameters

StreamsConfig(params object[])

Parameters

Properties

ACCEPTABLE_RECOVERY_LAG_CONFIG

Property Value

ADMIN_CLIENT_PREFIX

Property Value

APPLICATION_ID_CONFIG

Property Value

APPLICATION_SERVER_CONFIG

Property Value

AT_LEAST_ONCE

Property Value

BOOTSTRAP_SERVERS_CONFIG

Property Value

BUFFERED_RECORDS_PER_PARTITION_CONFIG

Property Value

BUFFERED_RECORDS_PER_PARTITION_DOC

Property Value

BUILT_IN_METRICS_VERSION_CONFIG

Property Value

BridgeClassName

Property Value

CACHE_MAX_BYTES_BUFFERING_DOC

Property Value

CLIENT_ID_CONFIG

Property Value

CLIENT_TAG_PREFIX

Property Value

COMMIT_INTERVAL_MS_CONFIG

Property Value

CONNECTIONS_MAX_IDLE_MS_CONFIG

Property Value

CONSUMER_PREFIX

Property Value

ClientTags

Property Value

DEFAULT_CLIENT_SUPPLIER_CONFIG

Property Value

DEFAULT_CLIENT_SUPPLIER_DOC

Property Value

DEFAULT_DESERIALIZATION_EXCEPTION_HANDLER_CLASS_CONFIG

Property Value

DEFAULT_DESERIALIZATION_EXCEPTION_HANDLER_CLASS_DOC

Property Value

DEFAULT_KEY_SERDE_CLASS_CONFIG

Property Value

DEFAULT_PRODUCTION_EXCEPTION_HANDLER_CLASS_CONFIG

Property Value

DEFAULT_TIMESTAMP_EXTRACTOR_CLASS_CONFIG

Property Value

DEFAULT_TIMESTAMP_EXTRACTOR_CLASS_DOC

Property Value

DEFAULT_VALUE_SERDE_CLASS_CONFIG

Property Value

DSL_STORE_SUPPLIERS_CLASS_CONFIG

Property Value

DUMMY_THREAD_INDEX

Property Value

ENABLE_METRICS_PUSH_CONFIG

Property Value

ENABLE_METRICS_PUSH_DOC

Property Value

EXACTLY_ONCE_V2

Property Value

GLOBAL_CONSUMER_PREFIX

Property Value

IsBridgeAbstract

Property Value

IsBridgeCloseable

Property Value

IsBridgeInterface

Property Value

IsBridgeStatic