Package io.confluent.connect.protobuf

Class ProtobufDataConfig

java.lang.Object

org.apache.kafka.common.config.AbstractConfig

io.confluent.connect.schema.AbstractDataConfig

io.confluent.connect.protobuf.ProtobufDataConfig

public class ProtobufDataConfig
extends AbstractDataConfig

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ProtobufDataConfig.Builder

Field Summary

Fields

Modifier and Type	Field	Description
static final String	ENHANCED_PROTOBUF_SCHEMA_SUPPORT_CONFIG
static final boolean	ENHANCED_PROTOBUF_SCHEMA_SUPPORT_DEFAULT
static final String	ENHANCED_PROTOBUF_SCHEMA_SUPPORT_DOC
static final String	FLATTEN_UNIONS_CONFIG
static final boolean	FLATTEN_UNIONS_DEFAULT
static final String	FLATTEN_UNIONS_DOC
static final String	GENERATE_INDEX_FOR_UNIONS_CONFIG
static final boolean	GENERATE_INDEX_FOR_UNIONS_DEFAULT
static final String	GENERATE_INDEX_FOR_UNIONS_DOC
static final String	GENERATE_STRUCT_FOR_NULLS_CONFIG
static final boolean	GENERATE_STRUCT_FOR_NULLS_DEFAULT
static final String	GENERATE_STRUCT_FOR_NULLS_DOC
static final String	INT_FOR_ENUMS_CONFIG
static final boolean	INT_FOR_ENUMS_DEFAULT
static final String	INT_FOR_ENUMS_DOC
static final String	OPTIONAL_FOR_NULLABLES_CONFIG
static final boolean	OPTIONAL_FOR_NULLABLES_DEFAULT
static final String	OPTIONAL_FOR_NULLABLES_DOC
static final String	OPTIONAL_FOR_PROTO2_CONFIG
static final boolean	OPTIONAL_FOR_PROTO2_DEFAULT
static final String	OPTIONAL_FOR_PROTO2_DOC
static final String	SCRUB_INVALID_NAMES_CONFIG
static final boolean	SCRUB_INVALID_NAMES_DEFAULT
static final String	SCRUB_INVALID_NAMES_DOC
static final String	WRAPPER_FOR_NULLABLES_CONFIG
static final boolean	WRAPPER_FOR_NULLABLES_DEFAULT
static final String	WRAPPER_FOR_NULLABLES_DOC
static final String	WRAPPER_FOR_RAW_PRIMITIVES_CONFIG
static final boolean	WRAPPER_FOR_RAW_PRIMITIVES_DEFAULT
static final String	WRAPPER_FOR_RAW_PRIMITIVES_DOC

Fields inherited from class io.confluent.connect.schema.AbstractDataConfig

GENERALIZED_SUM_TYPE_SUPPORT_CONFIG, GENERALIZED_SUM_TYPE_SUPPORT_DEFAULT, GENERALIZED_SUM_TYPE_SUPPORT_DOC, IGNORE_DEFAULT_FOR_NULLABLES_CONFIG, IGNORE_DEFAULT_FOR_NULLABLES_DEFAULT, IGNORE_DEFAULT_FOR_NULLABLES_DOC, SCHEMAS_CACHE_SIZE_CONFIG, SCHEMAS_CACHE_SIZE_DEFAULT, SCHEMAS_CACHE_SIZE_DOC

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

AUTOMATIC_CONFIG_PROVIDERS_PROPERTY, CONFIG_PROVIDERS_CONFIG, CONFIG_PROVIDERS_DOC

Constructor Summary

Constructors

Constructor	Description
ProtobufDataConfig(Map<?,?> props)

Method Summary

Modifier and Type	Method	Description
static org.apache.kafka.common.config.ConfigDef	baseConfigDef()
boolean	flattenUnions()
boolean	generateIndexForUnions()
boolean	generateStructForNulls()
boolean	isEnhancedProtobufSchemaSupport()
boolean	isScrubInvalidNames()
boolean	supportOptionalForProto2()
boolean	useIntForEnums()
boolean	useOptionalForNullables()
boolean	useWrapperForNullables()
boolean	useWrapperForRawPrimitives()

Methods inherited from class io.confluent.connect.schema.AbstractDataConfig

ignoreDefaultForNullables, isGeneralizedSumTypeSupport, schemaCacheSize

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, preProcessParsedConfig, typeOf, unused, values, valuesWithPrefixAllOrNothing, valuesWithPrefixOverride

Methods inherited from class java.lang.Object

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

Field Details

ENHANCED_PROTOBUF_SCHEMA_SUPPORT_CONFIG

public static final String ENHANCED_PROTOBUF_SCHEMA_SUPPORT_CONFIG

See Also:

• Constant Field Values

ENHANCED_PROTOBUF_SCHEMA_SUPPORT_DEFAULT

public static final boolean ENHANCED_PROTOBUF_SCHEMA_SUPPORT_DEFAULT

See Also:

• Constant Field Values

ENHANCED_PROTOBUF_SCHEMA_SUPPORT_DOC

public static final String ENHANCED_PROTOBUF_SCHEMA_SUPPORT_DOC

See Also:

• Constant Field Values

SCRUB_INVALID_NAMES_CONFIG

public static final String SCRUB_INVALID_NAMES_CONFIG

See Also:

• Constant Field Values

SCRUB_INVALID_NAMES_DEFAULT

public static final boolean SCRUB_INVALID_NAMES_DEFAULT

See Also:

• Constant Field Values

SCRUB_INVALID_NAMES_DOC

public static final String SCRUB_INVALID_NAMES_DOC

See Also:

• Constant Field Values

INT_FOR_ENUMS_CONFIG

public static final String INT_FOR_ENUMS_CONFIG

See Also:

• Constant Field Values

INT_FOR_ENUMS_DEFAULT

public static final boolean INT_FOR_ENUMS_DEFAULT

See Also:

• Constant Field Values

INT_FOR_ENUMS_DOC

public static final String INT_FOR_ENUMS_DOC

See Also:

• Constant Field Values

OPTIONAL_FOR_NULLABLES_CONFIG

public static final String OPTIONAL_FOR_NULLABLES_CONFIG

See Also:

• Constant Field Values

OPTIONAL_FOR_NULLABLES_DEFAULT

public static final boolean OPTIONAL_FOR_NULLABLES_DEFAULT

See Also:

• Constant Field Values

OPTIONAL_FOR_NULLABLES_DOC

public static final String OPTIONAL_FOR_NULLABLES_DOC

See Also:

• Constant Field Values

OPTIONAL_FOR_PROTO2_CONFIG

public static final String OPTIONAL_FOR_PROTO2_CONFIG

See Also:

• Constant Field Values

OPTIONAL_FOR_PROTO2_DEFAULT

public static final boolean OPTIONAL_FOR_PROTO2_DEFAULT

See Also:

• Constant Field Values

OPTIONAL_FOR_PROTO2_DOC

public static final String OPTIONAL_FOR_PROTO2_DOC

See Also:

• Constant Field Values

WRAPPER_FOR_NULLABLES_CONFIG

public static final String WRAPPER_FOR_NULLABLES_CONFIG

See Also:

• Constant Field Values

WRAPPER_FOR_NULLABLES_DEFAULT

public static final boolean WRAPPER_FOR_NULLABLES_DEFAULT

See Also:

• Constant Field Values

WRAPPER_FOR_NULLABLES_DOC

public static final String WRAPPER_FOR_NULLABLES_DOC

See Also:

• Constant Field Values

WRAPPER_FOR_RAW_PRIMITIVES_CONFIG

public static final String WRAPPER_FOR_RAW_PRIMITIVES_CONFIG

See Also:

• Constant Field Values

WRAPPER_FOR_RAW_PRIMITIVES_DEFAULT

public static final boolean WRAPPER_FOR_RAW_PRIMITIVES_DEFAULT

See Also:

• Constant Field Values

WRAPPER_FOR_RAW_PRIMITIVES_DOC

public static final String WRAPPER_FOR_RAW_PRIMITIVES_DOC

See Also:

• Constant Field Values

GENERATE_STRUCT_FOR_NULLS_CONFIG

public static final String GENERATE_STRUCT_FOR_NULLS_CONFIG

See Also:

• Constant Field Values

GENERATE_STRUCT_FOR_NULLS_DEFAULT

public static final boolean GENERATE_STRUCT_FOR_NULLS_DEFAULT

See Also:

• Constant Field Values

GENERATE_STRUCT_FOR_NULLS_DOC

public static final String GENERATE_STRUCT_FOR_NULLS_DOC

See Also:

• Constant Field Values

GENERATE_INDEX_FOR_UNIONS_CONFIG

public static final String GENERATE_INDEX_FOR_UNIONS_CONFIG

See Also:

• Constant Field Values

GENERATE_INDEX_FOR_UNIONS_DEFAULT

public static final boolean GENERATE_INDEX_FOR_UNIONS_DEFAULT

See Also:

• Constant Field Values

GENERATE_INDEX_FOR_UNIONS_DOC

public static final String GENERATE_INDEX_FOR_UNIONS_DOC

See Also:

• Constant Field Values

FLATTEN_UNIONS_CONFIG

public static final String FLATTEN_UNIONS_CONFIG

See Also:

• Constant Field Values

FLATTEN_UNIONS_DEFAULT

public static final boolean FLATTEN_UNIONS_DEFAULT

See Also:

• Constant Field Values

FLATTEN_UNIONS_DOC

public static final String FLATTEN_UNIONS_DOC

See Also:

• Constant Field Values

Constructor Details

ProtobufDataConfig

public ProtobufDataConfig(Map<?,?> props)

Method Details

baseConfigDef

public static org.apache.kafka.common.config.ConfigDef baseConfigDef()

isEnhancedProtobufSchemaSupport

public boolean isEnhancedProtobufSchemaSupport()

isScrubInvalidNames

public boolean isScrubInvalidNames()

useIntForEnums

public boolean useIntForEnums()

useOptionalForNullables

public boolean useOptionalForNullables()

supportOptionalForProto2

public boolean supportOptionalForProto2()

useWrapperForNullables

public boolean useWrapperForNullables()

useWrapperForRawPrimitives

public boolean useWrapperForRawPrimitives()

generateStructForNulls

public boolean generateStructForNulls()

generateIndexForUnions

public boolean generateIndexForUnions()

flattenUnions

public boolean flattenUnions()