private void updateBatchForRegionByTopic()

in src/main/java/org/apache/geode/kafka/sink/GeodeKafkaSinkTask.java [113:119]

• 7 lines of code
• 2 McCabe index (conditional complexity)

  private void updateBatchForRegionByTopic(SinkRecord sinkRecord,
      Map<String, BatchRecords> batchRecordsMap) {
    Collection<String> regionsToUpdate = topicToRegions.get(sinkRecord.topic());
    for (String region : regionsToUpdate) {
      updateBatchRecordsForRecord(sinkRecord, batchRecordsMap, region);
    }
  }