in src/main/java/org/apache/geode/kafka/sink/GeodeSinkConnectorConfig.java [49:75]
protected static ConfigDef configurables() {
ConfigDef configDef = GeodeConnectorConfig.configurables();
configDef.define(
TOPIC_TO_REGION_BINDINGS,
ConfigDef.Type.STRING,
DEFAULT_TOPIC_TO_REGION_BINDING,
ConfigDef.Importance.HIGH,
TOPIC_TO_REGION_BINDINGS_DOCUMENTATION,
SINK_GROUP,
1,
ConfigDef.Width.MEDIUM,
TOPIC_TO_REGION_BINDINGS_DISPLAY_NAME);
configDef.define(
NULL_VALUES_BEHAVIOR,
ConfigDef.Type.STRING,
DEFAULT_NULL_VALUES_BEHAVIOR,
EnumValidator.in(GeodeSinkConfigurationConstants.NullValueBehavior.values()),
ConfigDef.Importance.MEDIUM,
NULL_VALUES_BEHAVIOR_DOCUMENTATION,
SINK_GROUP,
2,
ConfigDef.Width.MEDIUM,
NULL_VALUES_BEHAVIOR_DISPLAY_NAME,
EnumRecommender.in(GeodeSinkConfigurationConstants.NullValueBehavior.values()));
return configDef;
}