Skip to content

Commit 23871e7

Browse files
Removed casted Function for lambda. Fixes 201. (#202)
1 parent 1e9cbd3 commit 23871e7

File tree

1 file changed

+1
-2
lines changed
  • connect-utils-testing/src/main/java/com/github/jcustenborder/kafka/connect/utils/templates

1 file changed

+1
-2
lines changed

connect-utils-testing/src/main/java/com/github/jcustenborder/kafka/connect/utils/templates/PluginLoader.java

+1-2
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,6 @@
1717

1818

1919
import com.github.jcustenborder.kafka.connect.utils.config.ConfigKeyComparator;
20-
import com.google.common.base.Function;
2120
import com.google.common.base.Strings;
2221
import com.google.common.collect.ImmutableSet;
2322
import org.apache.kafka.common.config.ConfigDef;
@@ -226,7 +225,7 @@ Plugin.Configuration config(Class<?> pluginClass) {
226225
.validator(configKey.validator)
227226
.build();
228227

229-
ImmutableGroup.Builder groupBuilder = groupBuilderCache.computeIfAbsent(group, (Function<String, ImmutableGroup.Builder>) s -> ImmutableGroup.builder().name(group));
228+
ImmutableGroup.Builder groupBuilder = groupBuilderCache.computeIfAbsent(group, s -> ImmutableGroup.builder().name(group));
230229
groupBuilder.addItems(item);
231230
if (item.isRequired()) {
232231
configBuilder.addRequiredConfigs(item);

0 commit comments

Comments
 (0)