Package org.gridgain.kafka

Class AbstractGridGainConnectorConfig

java.lang.Object

org.apache.kafka.common.config.AbstractConfig

org.gridgain.kafka.AbstractGridGainConnectorConfig

Direct Known Subclasses:

GridGainSinkConnectorConfig

public abstract class AbstractGridGainConnectorConfig
extends org.apache.kafka.common.config.AbstractConfig

Abstract GridGain connector configuration.

Field Summary

Fields inherited from class org.apache.kafka.common.config.AbstractConfig

AUTOMATIC_CONFIG_PROVIDERS_PROPERTY, CONFIG_PROVIDERS_CONFIG

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractGridGainConnectorConfig(org.apache.kafka.common.config.ConfigDef cfg, Map<String,String> props)

Method Summary

Modifier and Type	Method	Description
protected static org.apache.kafka.common.config.ConfigDef	baseConf()
IgniteClient.Builder	clientBuilder()	Creates Ignite client builder from the configuration.
String	igniteAddresses()
String	igniteAuthenticatorBasicPassword()
String	igniteAuthenticatorBasicUsername()
long	igniteBackgroundReconnectInterval()
long	igniteConnectTimeout()
long	igniteHeartbeatInterval()
long	igniteHeartbeatTimeout()
@Nullable List<String>	igniteSslCiphers()
boolean	igniteSslEnabled()
String	igniteSslKeyStorePassword()
String	igniteSslKeyStorePath()
String	igniteSslTrustStorePassword()
String	igniteSslTrustStorePath()

Methods inherited from class org.apache.kafka.common.config.AbstractConfig

documentationOf, equals, get, getBoolean, getClass, getConfiguredInstance, getConfiguredInstance, getConfiguredInstances, getConfiguredInstances, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, nonInternalValues, originals, originals, originalsStrings, originalsWithPrefix, originalsWithPrefix, postProcessParsedConfig, typeOf, unused, values, valuesWithPrefixAllOrNothing, valuesWithPrefixOverride

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Constructor Details

AbstractGridGainConnectorConfig

protected AbstractGridGainConnectorConfig(org.apache.kafka.common.config.ConfigDef cfg,
 Map<String,String> props)

Method Details

baseConf

protected static org.apache.kafka.common.config.ConfigDef baseConf()

igniteAddresses

public String igniteAddresses()

igniteConnectTimeout

public long igniteConnectTimeout()

igniteBackgroundReconnectInterval

public long igniteBackgroundReconnectInterval()

igniteHeartbeatInterval

public long igniteHeartbeatInterval()

igniteHeartbeatTimeout

public long igniteHeartbeatTimeout()

igniteSslEnabled

public boolean igniteSslEnabled()

igniteSslCiphers

@Nullable
public @Nullable List<String> igniteSslCiphers()

igniteSslKeyStorePath

public String igniteSslKeyStorePath()

igniteSslKeyStorePassword

public String igniteSslKeyStorePassword()

igniteSslTrustStorePath

public String igniteSslTrustStorePath()

igniteSslTrustStorePassword

public String igniteSslTrustStorePassword()

igniteAuthenticatorBasicUsername

public String igniteAuthenticatorBasicUsername()

igniteAuthenticatorBasicPassword

public String igniteAuthenticatorBasicPassword()

clientBuilder

public IgniteClient.Builder clientBuilder()

Creates Ignite client builder from the configuration.

Returns:

Ignite client builder.