Class ConsumerConfig
public class ConsumerConfig : AbstractConfig, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition, IJVMBridgeMain
- Inheritance
-
JVMBridgeBaseJVMBridgeBase<AbstractConfig>ConsumerConfig
- Implements
-
IJVMBridgeCoreIJVMBridgeBaseStaticIJVMBridgeBaseIJVMBridgeDefinitionIJVMBridgeMain
- Inherited Members
-
JVMBridgeBase<AbstractConfig>.IsAssignableFrom(IJavaType)JVMBridgeBase<AbstractConfig>.IsAssignableFrom<T>()JVMBridgeBase<AbstractConfig>.Execute<T>(params T[])JVMBridgeBase<AbstractConfig>.DynBridgeClazzJVMBridgeBase<AbstractConfig>.BridgeClazzJVMBridgeBase.RuntimeClassNameOf<T>()JVMBridgeBase.ClassNameOf<T>()JVMBridgeBase.ClassOf<T>()JVMBridgeBase.WrapsDirect<TNewClass>(IJavaObject)JVMBridgeBase.Wraps<TNewClass>(IJavaObject)JVMBridgeBase.Wraps<TNewClass, TReturn>(IJavaObject)JVMBridgeBase.Wraps<TNewClass, TReturn, TConverter>(IJavaObject)JVMBridgeBase.MonitorEnter()JVMBridgeBase.MonitorExit()JVMBridgeBase.IsInstanceOf(IJavaType)JVMBridgeBase.IsInstanceOf<T>()JVMBridgeBase.RuntimeIsInstanceOf<T>()JVMBridgeBase.CastTo<TNewClass>()JVMBridgeBase.CastDirect<TNewClass>()JVMBridgeBase.Dispose()JVMBridgeBase.ToString()JVMBridgeBase.GetHashCode()JVMBridgeBase.Notify()JVMBridgeBase.NotifyAll()JVMBridgeBase.Wait()JVMBridgeBase.IExecuteWithSignature<TNewClass, TReturn, TConverter>(string, string, params object[])JVMBridgeBase.DynBridgeInstanceJVMBridgeBase.BridgeInstanceJVMBridgeBase.IsBridgeListener
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>)
public ConsumerConfig(Map<String, object> arg0)
Parameters
ConsumerConfig(Properties)
public ConsumerConfig(Properties arg0)
Parameters
arg0
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
public static String ALLOW_AUTO_CREATE_TOPICS_CONFIG { get; }
Property Value
ASSIGN_FROM_SUBSCRIBED_ASSIGNORS
public static List ASSIGN_FROM_SUBSCRIBED_ASSIGNORS { get; }
Property Value
AUTO_COMMIT_INTERVAL_MS_CONFIG
public static String AUTO_COMMIT_INTERVAL_MS_CONFIG { get; }
Property Value
AUTO_OFFSET_RESET_CONFIG
public static String AUTO_OFFSET_RESET_CONFIG { get; }
Property Value
AUTO_OFFSET_RESET_DOC
public static String AUTO_OFFSET_RESET_DOC { get; }
Property Value
BOOTSTRAP_SERVERS_CONFIG
public static String BOOTSTRAP_SERVERS_CONFIG { get; }
Property Value
BridgeClassName
https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeBase_BridgeClassName.htm
public override string BridgeClassName { get; }
Property Value
CHECK_CRCS_CONFIG
public static String CHECK_CRCS_CONFIG { get; }
Property Value
CLIENT_DNS_LOOKUP_CONFIG
public static String CLIENT_DNS_LOOKUP_CONFIG { get; }
Property Value
CLIENT_ID_CONFIG
public static String CLIENT_ID_CONFIG { get; }
Property Value
CLIENT_RACK_CONFIG
public static String CLIENT_RACK_CONFIG { get; }
Property Value
CONNECTIONS_MAX_IDLE_MS_CONFIG
public static String CONNECTIONS_MAX_IDLE_MS_CONFIG { get; }
Property Value
DEFAULT_ALLOW_AUTO_CREATE_TOPICS
public static bool DEFAULT_ALLOW_AUTO_CREATE_TOPICS { get; }
Property Value
DEFAULT_API_TIMEOUT_MS_CONFIG
public static String DEFAULT_API_TIMEOUT_MS_CONFIG { get; }
Property Value
DEFAULT_CLIENT_RACK
public static String DEFAULT_CLIENT_RACK { get; }
Property Value
DEFAULT_EXCLUDE_INTERNAL_TOPICS
public static bool DEFAULT_EXCLUDE_INTERNAL_TOPICS { get; }
Property Value
DEFAULT_FETCH_MAX_BYTES
public static int DEFAULT_FETCH_MAX_BYTES { get; }
Property Value
DEFAULT_FETCH_MAX_WAIT_MS
public static int DEFAULT_FETCH_MAX_WAIT_MS { get; }
Property Value
DEFAULT_FETCH_MIN_BYTES
public static int DEFAULT_FETCH_MIN_BYTES { get; }
Property Value
DEFAULT_GROUP_PROTOCOL
public static String DEFAULT_GROUP_PROTOCOL { get; }
Property Value
DEFAULT_GROUP_REMOTE_ASSIGNOR
public static String DEFAULT_GROUP_REMOTE_ASSIGNOR { get; }
Property Value
DEFAULT_ISOLATION_LEVEL
public static String DEFAULT_ISOLATION_LEVEL { get; }
Property Value
DEFAULT_MAX_PARTITION_FETCH_BYTES
public static int DEFAULT_MAX_PARTITION_FETCH_BYTES { get; }
Property Value
DEFAULT_MAX_POLL_RECORDS
public static int DEFAULT_MAX_POLL_RECORDS { get; }
Property Value
ENABLE_AUTO_COMMIT_CONFIG
public static String ENABLE_AUTO_COMMIT_CONFIG { get; }
Property Value
ENABLE_METRICS_PUSH_CONFIG
public static String ENABLE_METRICS_PUSH_CONFIG { get; }
Property Value
ENABLE_METRICS_PUSH_DOC
public static String ENABLE_METRICS_PUSH_DOC { get; }
Property Value
EXCLUDE_INTERNAL_TOPICS_CONFIG
public static String EXCLUDE_INTERNAL_TOPICS_CONFIG { get; }
Property Value
FETCH_MAX_BYTES_CONFIG
public static String FETCH_MAX_BYTES_CONFIG { get; }
Property Value
FETCH_MAX_WAIT_MS_CONFIG
public static String FETCH_MAX_WAIT_MS_CONFIG { get; }
Property Value
FETCH_MIN_BYTES_CONFIG
public static String FETCH_MIN_BYTES_CONFIG { get; }
Property Value
GROUP_ID_CONFIG
public static String GROUP_ID_CONFIG { get; }
Property Value
GROUP_INSTANCE_ID_CONFIG
public static String GROUP_INSTANCE_ID_CONFIG { get; }
Property Value
GROUP_PROTOCOL_CONFIG
public static String GROUP_PROTOCOL_CONFIG { get; }
Property Value
GROUP_PROTOCOL_DOC
public static String GROUP_PROTOCOL_DOC { get; }
Property Value
GROUP_REMOTE_ASSIGNOR_CONFIG
public static String GROUP_REMOTE_ASSIGNOR_CONFIG { get; }
Property Value
GROUP_REMOTE_ASSIGNOR_DOC
public static String GROUP_REMOTE_ASSIGNOR_DOC { get; }
Property Value
HEARTBEAT_INTERVAL_MS_CONFIG
public static String HEARTBEAT_INTERVAL_MS_CONFIG { get; }
Property Value
INTERCEPTOR_CLASSES_CONFIG
public static String INTERCEPTOR_CLASSES_CONFIG { get; }
Property Value
INTERCEPTOR_CLASSES_DOC
public static String INTERCEPTOR_CLASSES_DOC { get; }
Property Value
ISOLATION_LEVEL_CONFIG
public static String ISOLATION_LEVEL_CONFIG { get; }
Property Value
ISOLATION_LEVEL_DOC
public static String ISOLATION_LEVEL_DOC { get; }
Property Value
IsBridgeAbstract
public override bool IsBridgeAbstract { get; }
Property Value
IsBridgeCloseable
public override bool IsBridgeCloseable { get; }
Property Value
IsBridgeInterface
public override bool IsBridgeInterface { get; }
Property Value
IsBridgeStatic
public override bool IsBridgeStatic { get; }
Property Value
KEY_DESERIALIZER_CLASS_CONFIG
public static String KEY_DESERIALIZER_CLASS_CONFIG { get; }
Property Value
KEY_DESERIALIZER_CLASS_DOC
public static String KEY_DESERIALIZER_CLASS_DOC { get; }
Property Value
MAX_PARTITION_FETCH_BYTES_CONFIG
public static String MAX_PARTITION_FETCH_BYTES_CONFIG { get; }
Property Value
MAX_POLL_INTERVAL_MS_CONFIG
public static String MAX_POLL_INTERVAL_MS_CONFIG { get; }
Property Value
MAX_POLL_RECORDS_CONFIG
public static String MAX_POLL_RECORDS_CONFIG { get; }
Property Value
METADATA_MAX_AGE_CONFIG
public static String METADATA_MAX_AGE_CONFIG { get; }
Property Value
METRICS_NUM_SAMPLES_CONFIG
public static String METRICS_NUM_SAMPLES_CONFIG { get; }
Property Value
METRICS_RECORDING_LEVEL_CONFIG
public static String METRICS_RECORDING_LEVEL_CONFIG { get; }
Property Value
METRICS_SAMPLE_WINDOW_MS_CONFIG
public static String METRICS_SAMPLE_WINDOW_MS_CONFIG { get; }
Property Value
METRIC_REPORTER_CLASSES_CONFIG
public static String METRIC_REPORTER_CLASSES_CONFIG { get; }
Property Value
PARTITION_ASSIGNMENT_STRATEGY_CONFIG
public static String PARTITION_ASSIGNMENT_STRATEGY_CONFIG { get; }
Property Value
RECEIVE_BUFFER_CONFIG
public static String RECEIVE_BUFFER_CONFIG { get; }
Property Value
RECONNECT_BACKOFF_MAX_MS_CONFIG
public static String RECONNECT_BACKOFF_MAX_MS_CONFIG { get; }
Property Value
RECONNECT_BACKOFF_MS_CONFIG
public static String RECONNECT_BACKOFF_MS_CONFIG { get; }
Property Value
REQUEST_TIMEOUT_MS_CONFIG
public static String REQUEST_TIMEOUT_MS_CONFIG { get; }
Property Value
RETRY_BACKOFF_MAX_MS_CONFIG
public static String RETRY_BACKOFF_MAX_MS_CONFIG { get; }
Property Value
RETRY_BACKOFF_MS_CONFIG
public static String RETRY_BACKOFF_MS_CONFIG { get; }
Property Value
SECURITY_PROVIDERS_CONFIG
public static String SECURITY_PROVIDERS_CONFIG { get; }
Property Value
SEND_BUFFER_CONFIG
public static String SEND_BUFFER_CONFIG { get; }
Property Value
SESSION_TIMEOUT_MS_CONFIG
public static String SESSION_TIMEOUT_MS_CONFIG { get; }
Property Value
SOCKET_CONNECTION_SETUP_TIMEOUT_MAX_MS_CONFIG
public static String SOCKET_CONNECTION_SETUP_TIMEOUT_MAX_MS_CONFIG { get; }
Property Value
SOCKET_CONNECTION_SETUP_TIMEOUT_MS_CONFIG
public static String SOCKET_CONNECTION_SETUP_TIMEOUT_MS_CONFIG { get; }
Property Value
VALUE_DESERIALIZER_CLASS_CONFIG
public static String VALUE_DESERIALIZER_CLASS_CONFIG { get; }
Property Value
VALUE_DESERIALIZER_CLASS_DOC
public static String VALUE_DESERIALIZER_CLASS_DOC { get; }
Property Value
Methods
AppendDeserializerToConfig(Map<String, object>, Deserializer<object>, Deserializer<object>)
public static Map<String, object> AppendDeserializerToConfig(Map<String, object> arg0, Deserializer<object> arg1, Deserializer<object> arg2)
Parameters
arg0
Map<String, object>arg1
Deserializer<object>arg2
Deserializer<object>
Returns
ConfigDef()
public static ConfigDef ConfigDef()
Returns
ConfigNames()
public static Set<String> ConfigNames()
Returns
Main(String[])
public static void Main(String[] arg0)