Class ProducerConfig

Namespace

Org.Apache.Kafka.Clients.Producer

Assembly

MASES.KNet.dll

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.html

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

Inheritance

object

DynamicObject

JVMBridgeBase

JVMBridgeBase<AbstractConfig>

AbstractConfig

ProducerConfig

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

ProducerConfig()

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

public ProducerConfig()

ProducerConfig(Map<String, object>)

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

public ProducerConfig(Map<String, object> arg0)

Parameters

arg0 Map<String, object>

Map

ProducerConfig(Properties)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.html#org.apache.kafka.clients.producer.ProducerConfig(java.util.Properties)

public ProducerConfig(Properties arg0)

Parameters

arg0 Properties

Properties

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

Parameters

args object[]

Properties

ACKS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.html#ACKS_CONFIG

public static String ACKS_CONFIG { get; }

Property Value

String

BATCH_SIZE_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.html#BATCH_SIZE_CONFIG

public static String BATCH_SIZE_CONFIG { get; }

Property Value

String

BOOTSTRAP_SERVERS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.html#BOOTSTRAP_SERVERS_CONFIG

public static String BOOTSTRAP_SERVERS_CONFIG { get; }

Property Value

String

BUFFER_MEMORY_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.html#BUFFER_MEMORY_CONFIG

public static String BUFFER_MEMORY_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

CLIENT_DNS_LOOKUP_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.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/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.html#CLIENT_ID_CONFIG

public static String CLIENT_ID_CONFIG { get; }

Property Value

String

COMPRESSION_GZIP_LEVEL_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.html#COMPRESSION_GZIP_LEVEL_CONFIG

public static String COMPRESSION_GZIP_LEVEL_CONFIG { get; }

Property Value

String

COMPRESSION_LZ4_LEVEL_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.html#COMPRESSION_LZ4_LEVEL_CONFIG

public static String COMPRESSION_LZ4_LEVEL_CONFIG { get; }

Property Value

String

COMPRESSION_TYPE_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.html#COMPRESSION_TYPE_CONFIG

public static String COMPRESSION_TYPE_CONFIG { get; }

Property Value

String

COMPRESSION_ZSTD_LEVEL_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.html#COMPRESSION_ZSTD_LEVEL_CONFIG

public static String COMPRESSION_ZSTD_LEVEL_CONFIG { get; }

Property Value

String

CONNECTIONS_MAX_IDLE_MS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.html#CONNECTIONS_MAX_IDLE_MS_CONFIG

public static String CONNECTIONS_MAX_IDLE_MS_CONFIG { get; }

Property Value

String

DELIVERY_TIMEOUT_MS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.html#DELIVERY_TIMEOUT_MS_CONFIG

public static String DELIVERY_TIMEOUT_MS_CONFIG { get; }

Property Value

String

ENABLE_IDEMPOTENCE_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.html#ENABLE_IDEMPOTENCE_CONFIG

public static String ENABLE_IDEMPOTENCE_CONFIG { get; }

Property Value

String

ENABLE_IDEMPOTENCE_DOC

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.html#ENABLE_IDEMPOTENCE_DOC

public static String ENABLE_IDEMPOTENCE_DOC { get; }

Property Value

String

ENABLE_METRICS_PUSH_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.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/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.html#ENABLE_METRICS_PUSH_DOC

public static String ENABLE_METRICS_PUSH_DOC { get; }

Property Value

String

INTERCEPTOR_CLASSES_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.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/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.html#INTERCEPTOR_CLASSES_DOC

public static String INTERCEPTOR_CLASSES_DOC { 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

KEY_SERIALIZER_CLASS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.html#KEY_SERIALIZER_CLASS_CONFIG

public static String KEY_SERIALIZER_CLASS_CONFIG { get; }

Property Value

String

KEY_SERIALIZER_CLASS_DOC

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.html#KEY_SERIALIZER_CLASS_DOC

public static String KEY_SERIALIZER_CLASS_DOC { get; }

Property Value

String

LINGER_MS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.html#LINGER_MS_CONFIG

public static String LINGER_MS_CONFIG { get; }

Property Value

String

MAX_BLOCK_MS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.html#MAX_BLOCK_MS_CONFIG

public static String MAX_BLOCK_MS_CONFIG { get; }

Property Value

String

MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.html#MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION

public static String MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION { get; }

Property Value

String

MAX_REQUEST_SIZE_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.html#MAX_REQUEST_SIZE_CONFIG

public static String MAX_REQUEST_SIZE_CONFIG { get; }

Property Value

String

METADATA_MAX_AGE_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.html#METADATA_MAX_AGE_CONFIG

public static String METADATA_MAX_AGE_CONFIG { get; }

Property Value

String

METADATA_MAX_IDLE_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.html#METADATA_MAX_IDLE_CONFIG

public static String METADATA_MAX_IDLE_CONFIG { get; }

Property Value

String

METRICS_NUM_SAMPLES_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.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/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.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/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.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/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.html#METRIC_REPORTER_CLASSES_CONFIG

public static String METRIC_REPORTER_CLASSES_CONFIG { get; }

Property Value

String

PARTITIONER_ADPATIVE_PARTITIONING_ENABLE_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.html#PARTITIONER_ADPATIVE_PARTITIONING_ENABLE_CONFIG

public static String PARTITIONER_ADPATIVE_PARTITIONING_ENABLE_CONFIG { get; }

Property Value

String

PARTITIONER_AVAILABILITY_TIMEOUT_MS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.html#PARTITIONER_AVAILABILITY_TIMEOUT_MS_CONFIG

public static String PARTITIONER_AVAILABILITY_TIMEOUT_MS_CONFIG { get; }

Property Value

String

PARTITIONER_CLASS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.html#PARTITIONER_CLASS_CONFIG

public static String PARTITIONER_CLASS_CONFIG { get; }

Property Value

String

PARTITIONER_IGNORE_KEYS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.html#PARTITIONER_IGNORE_KEYS_CONFIG

public static String PARTITIONER_IGNORE_KEYS_CONFIG { get; }

Property Value

String

RECEIVE_BUFFER_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.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/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.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/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.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/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.html#REQUEST_TIMEOUT_MS_CONFIG

public static String REQUEST_TIMEOUT_MS_CONFIG { get; }

Property Value

String

RETRIES_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.html#RETRIES_CONFIG

public static String RETRIES_CONFIG { get; }

Property Value

String

RETRY_BACKOFF_MAX_MS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.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/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.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/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.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/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.html#SEND_BUFFER_CONFIG

public static String SEND_BUFFER_CONFIG { get; }

Property Value

String

SOCKET_CONNECTION_SETUP_TIMEOUT_MAX_MS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.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/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.html#SOCKET_CONNECTION_SETUP_TIMEOUT_MS_CONFIG

public static String SOCKET_CONNECTION_SETUP_TIMEOUT_MS_CONFIG { get; }

Property Value

String

TRANSACTIONAL_ID_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.html#TRANSACTIONAL_ID_CONFIG

public static String TRANSACTIONAL_ID_CONFIG { get; }

Property Value

String

TRANSACTIONAL_ID_DOC

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.html#TRANSACTIONAL_ID_DOC

public static String TRANSACTIONAL_ID_DOC { get; }

Property Value

String

TRANSACTION_TIMEOUT_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.html#TRANSACTION_TIMEOUT_CONFIG

public static String TRANSACTION_TIMEOUT_CONFIG { get; }

Property Value

String

TRANSACTION_TIMEOUT_DOC

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.html#TRANSACTION_TIMEOUT_DOC

public static String TRANSACTION_TIMEOUT_DOC { get; }

Property Value

String

VALUE_SERIALIZER_CLASS_CONFIG

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.html#VALUE_SERIALIZER_CLASS_CONFIG

public static String VALUE_SERIALIZER_CLASS_CONFIG { get; }

Property Value

String

VALUE_SERIALIZER_CLASS_DOC

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.html#VALUE_SERIALIZER_CLASS_DOC

public static String VALUE_SERIALIZER_CLASS_DOC { get; }

Property Value

String

Methods

ConfigDef()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.html#configDef--

public static ConfigDef ConfigDef()

Returns

ConfigDef

ConfigDef

ConfigNames()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/producer/ProducerConfig.html#configNames--

public static Set<String> ConfigNames()

Returns

Set<String>

Set

Main(String[])

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

public static void Main(String[] arg0)

Parameters

arg0 String[]

String