void configure()

in src/main/java/org/apache/geode/kafka/sink/GeodeKafkaSinkTask.java [83:87]

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

  void configure(GeodeSinkConnectorConfig geodeConnectorConfig) {
    logger.debug("GeodeKafkaSourceTask id:" + geodeConnectorConfig.getTaskId() + " starting");
    topicToRegions = geodeConnectorConfig.getTopicToRegions();
    nullValuesMeansRemove = geodeConnectorConfig.getNullValueBehavior();
  }