File tree Expand file tree Collapse file tree 1 file changed +5
-3
lines changed
src/main/java/io/confluent/kafka/connect/datagen Expand file tree Collapse file tree 1 file changed +5
-3
lines changed Original file line number Diff line number Diff line change 16
16
17
17
package io .confluent .kafka .connect .datagen ;
18
18
19
+ import com .google .common .collect .ImmutableSet ;
19
20
import io .confluent .avro .random .generator .Generator ;
20
21
import io .confluent .connect .avro .AvroData ;
21
22
import java .util .ArrayList ;
32
33
import java .util .concurrent .Future ;
33
34
import java .util .concurrent .TimeUnit ;
34
35
import java .util .concurrent .TimeoutException ;
35
- import java .util .stream .Collectors ;
36
36
import org .apache .avro .generic .GenericRecord ;
37
37
import org .apache .kafka .connect .data .Schema ;
38
38
import org .apache .kafka .connect .data .SchemaAndValue ;
@@ -90,10 +90,12 @@ protected enum Quickstart {
90
90
static final Set <String > configValues ;
91
91
92
92
static {
93
- configValues = Arrays .stream (Quickstart .values ())
93
+ ImmutableSet .Builder <String > immutableSetBuilder = ImmutableSet .builder ();
94
+ Arrays .stream (Quickstart .values ())
94
95
.map (Quickstart ::name )
95
96
.map (String ::toLowerCase )
96
- .collect (Collectors .toSet ());
97
+ .forEach (immutableSetBuilder ::add );
98
+ configValues = immutableSetBuilder .build ();
97
99
}
98
100
99
101
private final String schemaFilename ;
You can’t perform that action at this time.
0 commit comments