private Region createProxyRegion()

in src/main/java/org/apache/geode/kafka/sink/GeodeKafkaSinkTask.java [147:155]

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

  private Region<Object, Object> createProxyRegion(String regionName) {
    try {
      return geodeContext.getClientCache().createClientRegionFactory(ClientRegionShortcut.PROXY)
          .create(regionName);
    } catch (RegionExistsException e) {
      // Each task is a separate parallel task controlled by kafka.
      return geodeContext.getClientCache().getRegion(regionName);
    }
  }