public GeodeSinkConnectorConfig()

in src/main/java/org/apache/geode/kafka/sink/GeodeSinkConnectorConfig.java [42:47]

• 6 lines of code
• 1 McCabe index (conditional complexity)

  public GeodeSinkConnectorConfig(Map<String, String> connectorProperties) {
    super(SINK_CONFIG_DEF, connectorProperties);
    topicToRegions = parseTopicToRegions(getString(TOPIC_TO_REGION_BINDINGS));
    nullValueBehavior = GeodeSinkConfigurationConstants.NullValueBehavior
        .valueOf(getString(NULL_VALUES_BEHAVIOR).toUpperCase());
  }