Class ConsumerConfig

Namespace

Org.Apache.Kafka.Clients.Consumer

Assembly

MASES.KNet.dll

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html

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

Inheritance

object

DynamicObject

JVMBridgeBase

JVMBridgeBase<AbstractConfig>

AbstractConfig

ConsumerConfig

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

ConsumerConfig()

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

public ConsumerConfig()

ConsumerConfig(Map<String, object>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#%3Cinit%3E(java.util.Map)

public ConsumerConfig(Map<String, object> arg0)

Parameters

arg0 Map<String, object>

Map

ConsumerConfig(Properties)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#%3Cinit%3E(java.util.Properties)

public ConsumerConfig(Properties arg0)

Parameters

arg0 Properties

Properties

ConsumerConfig(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 ConsumerConfig(params object[] args)

Parameters

args object[]

Properties

ALLOW_AUTO_CREATE_TOPICS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#ALLOW_AUTO_CREATE_TOPICS_CONFIG

public static String ALLOW_AUTO_CREATE_TOPICS_CONFIG { get; }

Property Value

String

ASSIGN_FROM_SUBSCRIBED_ASSIGNORS

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#ASSIGN_FROM_SUBSCRIBED_ASSIGNORS

public static List ASSIGN_FROM_SUBSCRIBED_ASSIGNORS { get; }

Property Value

List

AUTO_COMMIT_INTERVAL_MS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#AUTO_COMMIT_INTERVAL_MS_CONFIG

public static String AUTO_COMMIT_INTERVAL_MS_CONFIG { get; }

Property Value

String

AUTO_OFFSET_RESET_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#AUTO_OFFSET_RESET_CONFIG

public static String AUTO_OFFSET_RESET_CONFIG { get; }

Property Value

String

AUTO_OFFSET_RESET_DOC

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#AUTO_OFFSET_RESET_DOC

public static String AUTO_OFFSET_RESET_DOC { get; }

Property Value

String

BOOTSTRAP_SERVERS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#BOOTSTRAP_SERVERS_CONFIG

public static String BOOTSTRAP_SERVERS_CONFIG { get; }

Property Value

String

BridgeClassName

Java class name to be instantiated

public override string BridgeClassName { get; }

Property Value

string

CHECK_CRCS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#CHECK_CRCS_CONFIG

public static String CHECK_CRCS_CONFIG { get; }

Property Value

String

CLIENT_DNS_LOOKUP_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#CLIENT_DNS_LOOKUP_CONFIG

public static String CLIENT_DNS_LOOKUP_CONFIG { get; }

Property Value

String

CLIENT_ID_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#CLIENT_ID_CONFIG

public static String CLIENT_ID_CONFIG { get; }

Property Value

String

CLIENT_RACK_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#CLIENT_RACK_CONFIG

public static String CLIENT_RACK_CONFIG { get; }

Property Value

String

CONNECTIONS_MAX_IDLE_MS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#CONNECTIONS_MAX_IDLE_MS_CONFIG

public static String CONNECTIONS_MAX_IDLE_MS_CONFIG { get; }

Property Value

String

DEFAULT_ALLOW_AUTO_CREATE_TOPICS

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#DEFAULT_ALLOW_AUTO_CREATE_TOPICS

public static bool DEFAULT_ALLOW_AUTO_CREATE_TOPICS { get; }

Property Value

bool

DEFAULT_API_TIMEOUT_MS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#DEFAULT_API_TIMEOUT_MS_CONFIG

public static String DEFAULT_API_TIMEOUT_MS_CONFIG { get; }

Property Value

String

DEFAULT_CLIENT_RACK

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#DEFAULT_CLIENT_RACK

public static String DEFAULT_CLIENT_RACK { get; }

Property Value

String

DEFAULT_EXCLUDE_INTERNAL_TOPICS

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#DEFAULT_EXCLUDE_INTERNAL_TOPICS

public static bool DEFAULT_EXCLUDE_INTERNAL_TOPICS { get; }

Property Value

bool

DEFAULT_FETCH_MAX_BYTES

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#DEFAULT_FETCH_MAX_BYTES

public static int DEFAULT_FETCH_MAX_BYTES { get; }

Property Value

int

DEFAULT_FETCH_MAX_WAIT_MS

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#DEFAULT_FETCH_MAX_WAIT_MS

public static int DEFAULT_FETCH_MAX_WAIT_MS { get; }

Property Value

int

DEFAULT_FETCH_MIN_BYTES

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#DEFAULT_FETCH_MIN_BYTES

public static int DEFAULT_FETCH_MIN_BYTES { get; }

Property Value

int

DEFAULT_GROUP_PROTOCOL

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#DEFAULT_GROUP_PROTOCOL

public static String DEFAULT_GROUP_PROTOCOL { get; }

Property Value

String

DEFAULT_GROUP_REMOTE_ASSIGNOR

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#DEFAULT_GROUP_REMOTE_ASSIGNOR

public static String DEFAULT_GROUP_REMOTE_ASSIGNOR { get; }

Property Value

String

DEFAULT_ISOLATION_LEVEL

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#DEFAULT_ISOLATION_LEVEL

public static String DEFAULT_ISOLATION_LEVEL { get; }

Property Value

String

DEFAULT_MAX_PARTITION_FETCH_BYTES

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#DEFAULT_MAX_PARTITION_FETCH_BYTES

public static int DEFAULT_MAX_PARTITION_FETCH_BYTES { get; }

Property Value

int

DEFAULT_MAX_POLL_RECORDS

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#DEFAULT_MAX_POLL_RECORDS

public static int DEFAULT_MAX_POLL_RECORDS { get; }

Property Value

int

ENABLE_AUTO_COMMIT_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#ENABLE_AUTO_COMMIT_CONFIG

public static String ENABLE_AUTO_COMMIT_CONFIG { get; }

Property Value

String

ENABLE_METRICS_PUSH_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.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-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#ENABLE_METRICS_PUSH_DOC

public static String ENABLE_METRICS_PUSH_DOC { get; }

Property Value

String

EXCLUDE_INTERNAL_TOPICS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#EXCLUDE_INTERNAL_TOPICS_CONFIG

public static String EXCLUDE_INTERNAL_TOPICS_CONFIG { get; }

Property Value

String

FETCH_MAX_BYTES_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#FETCH_MAX_BYTES_CONFIG

public static String FETCH_MAX_BYTES_CONFIG { get; }

Property Value

String

FETCH_MAX_WAIT_MS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#FETCH_MAX_WAIT_MS_CONFIG

public static String FETCH_MAX_WAIT_MS_CONFIG { get; }

Property Value

String

FETCH_MIN_BYTES_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#FETCH_MIN_BYTES_CONFIG

public static String FETCH_MIN_BYTES_CONFIG { get; }

Property Value

String

GROUP_ID_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#GROUP_ID_CONFIG

public static String GROUP_ID_CONFIG { get; }

Property Value

String

GROUP_INSTANCE_ID_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#GROUP_INSTANCE_ID_CONFIG

public static String GROUP_INSTANCE_ID_CONFIG { get; }

Property Value

String

GROUP_PROTOCOL_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#GROUP_PROTOCOL_CONFIG

public static String GROUP_PROTOCOL_CONFIG { get; }

Property Value

String

GROUP_PROTOCOL_DOC

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#GROUP_PROTOCOL_DOC

public static String GROUP_PROTOCOL_DOC { get; }

Property Value

String

GROUP_REMOTE_ASSIGNOR_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#GROUP_REMOTE_ASSIGNOR_CONFIG

public static String GROUP_REMOTE_ASSIGNOR_CONFIG { get; }

Property Value

String

GROUP_REMOTE_ASSIGNOR_DOC

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#GROUP_REMOTE_ASSIGNOR_DOC

public static String GROUP_REMOTE_ASSIGNOR_DOC { get; }

Property Value

String

HEARTBEAT_INTERVAL_MS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#HEARTBEAT_INTERVAL_MS_CONFIG

public static String HEARTBEAT_INTERVAL_MS_CONFIG { get; }

Property Value

String

INTERCEPTOR_CLASSES_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#INTERCEPTOR_CLASSES_CONFIG

public static String INTERCEPTOR_CLASSES_CONFIG { get; }

Property Value

String

INTERCEPTOR_CLASSES_DOC

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#INTERCEPTOR_CLASSES_DOC

public static String INTERCEPTOR_CLASSES_DOC { get; }

Property Value

String

ISOLATION_LEVEL_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#ISOLATION_LEVEL_CONFIG

public static String ISOLATION_LEVEL_CONFIG { get; }

Property Value

String

ISOLATION_LEVEL_DOC

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#ISOLATION_LEVEL_DOC

public static String ISOLATION_LEVEL_DOC { get; }

Property Value

String

IsBridgeAbstract

true if the BridgeClassName is an abstract class, i.e. cannot be created an instance

public override bool IsBridgeAbstract { get; }

Property Value

bool

IsBridgeCloseable

true if the BridgeClassName implements Closeable

public override bool IsBridgeCloseable { get; }

Property Value

bool

IsBridgeInterface

true if the BridgeClassName is an interface, i.e. does not have any public constructor

public override bool IsBridgeInterface { get; }

Property Value

bool

IsBridgeStatic

true if the BridgeClassName is a static class, i.e. does not have any public constructor

public override bool IsBridgeStatic { get; }

Property Value

bool

KEY_DESERIALIZER_CLASS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#KEY_DESERIALIZER_CLASS_CONFIG

public static String KEY_DESERIALIZER_CLASS_CONFIG { get; }

Property Value

String

KEY_DESERIALIZER_CLASS_DOC

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#KEY_DESERIALIZER_CLASS_DOC

public static String KEY_DESERIALIZER_CLASS_DOC { get; }

Property Value

String

MAX_PARTITION_FETCH_BYTES_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#MAX_PARTITION_FETCH_BYTES_CONFIG

public static String MAX_PARTITION_FETCH_BYTES_CONFIG { get; }

Property Value

String

MAX_POLL_INTERVAL_MS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#MAX_POLL_INTERVAL_MS_CONFIG

public static String MAX_POLL_INTERVAL_MS_CONFIG { get; }

Property Value

String

MAX_POLL_RECORDS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#MAX_POLL_RECORDS_CONFIG

public static String MAX_POLL_RECORDS_CONFIG { get; }

Property Value

String

METADATA_MAX_AGE_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#METADATA_MAX_AGE_CONFIG

public static String METADATA_MAX_AGE_CONFIG { get; }

Property Value

String

METRICS_NUM_SAMPLES_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.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-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.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-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.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-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#METRIC_REPORTER_CLASSES_CONFIG

public static String METRIC_REPORTER_CLASSES_CONFIG { get; }

Property Value

String

PARTITION_ASSIGNMENT_STRATEGY_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#PARTITION_ASSIGNMENT_STRATEGY_CONFIG

public static String PARTITION_ASSIGNMENT_STRATEGY_CONFIG { get; }

Property Value

String

RECEIVE_BUFFER_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.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-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.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-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#RECONNECT_BACKOFF_MS_CONFIG

public static String RECONNECT_BACKOFF_MS_CONFIG { get; }

Property Value

String

REQUEST_TIMEOUT_MS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#REQUEST_TIMEOUT_MS_CONFIG

public static String REQUEST_TIMEOUT_MS_CONFIG { get; }

Property Value

String

RETRY_BACKOFF_MAX_MS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#RETRY_BACKOFF_MAX_MS_CONFIG

public static String RETRY_BACKOFF_MAX_MS_CONFIG { get; }

Property Value

String

RETRY_BACKOFF_MS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#RETRY_BACKOFF_MS_CONFIG

public static String RETRY_BACKOFF_MS_CONFIG { get; }

Property Value

String

SECURITY_PROVIDERS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#SECURITY_PROVIDERS_CONFIG

public static String SECURITY_PROVIDERS_CONFIG { get; }

Property Value

String

SEND_BUFFER_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#SEND_BUFFER_CONFIG

public static String SEND_BUFFER_CONFIG { get; }

Property Value

String

SESSION_TIMEOUT_MS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#SESSION_TIMEOUT_MS_CONFIG

public static String SESSION_TIMEOUT_MS_CONFIG { get; }

Property Value

String

SOCKET_CONNECTION_SETUP_TIMEOUT_MAX_MS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#SOCKET_CONNECTION_SETUP_TIMEOUT_MAX_MS_CONFIG

public static String SOCKET_CONNECTION_SETUP_TIMEOUT_MAX_MS_CONFIG { get; }

Property Value

String

SOCKET_CONNECTION_SETUP_TIMEOUT_MS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#SOCKET_CONNECTION_SETUP_TIMEOUT_MS_CONFIG

public static String SOCKET_CONNECTION_SETUP_TIMEOUT_MS_CONFIG { get; }

Property Value

String

VALUE_DESERIALIZER_CLASS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#VALUE_DESERIALIZER_CLASS_CONFIG

public static String VALUE_DESERIALIZER_CLASS_CONFIG { get; }

Property Value

String

VALUE_DESERIALIZER_CLASS_DOC

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#VALUE_DESERIALIZER_CLASS_DOC

public static String VALUE_DESERIALIZER_CLASS_DOC { get; }

Property Value

String

Methods

AppendDeserializerToConfig(Map<String, object>, Deserializer<object>, Deserializer<object>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#appendDeserializerToConfig(java.util.Map,org.apache.kafka.common.serialization.Deserializer,org.apache.kafka.common.serialization.Deserializer)

public static Map<String, object> AppendDeserializerToConfig(Map<String, object> arg0, Deserializer<object> arg1, Deserializer<object> arg2)

Parameters

arg0 Map<String, object>

Map

arg1 Deserializer<object>

Deserializer

arg2 Deserializer<object>

Deserializer

Returns

Map<String, object>

Map

ConfigDef()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#configDef()

public static ConfigDef ConfigDef()

Returns

ConfigDef

ConfigDef

ConfigNames()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#configNames()

public static Set<String> ConfigNames()

Returns

Set<String>

Set

Main(String[])

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/ConsumerConfig.html#main(java.lang.String[])

public static void Main(String[] arg0)

Parameters

arg0 String[]

String