File tree Expand file tree Collapse file tree 1 file changed +6
-4
lines changed
src/main/java/io/confluent/kafka/connect/datagen Expand file tree Collapse file tree 1 file changed +6
-4
lines changed Original file line number Diff line number Diff line change 19
19
import io .confluent .avro .random .generator .Generator ;
20
20
import io .confluent .connect .avro .AvroData ;
21
21
import java .util .ArrayList ;
22
+ import java .util .Arrays ;
22
23
import java .util .Collections ;
23
24
import java .util .HashMap ;
24
25
import java .util .HashSet ;
@@ -90,12 +91,13 @@ protected enum Quickstart {
90
91
STORES ("stores.avro" , "store_id" ),
91
92
CREDIT_CARDS ("credit_cards.avro" , "card_id" );
92
93
93
- static final Set <String > configValues = new HashSet <>() ;
94
+ static final Set <String > configValues ;
94
95
95
96
static {
96
- for (Quickstart q : Quickstart .values ()) {
97
- configValues .add (q .name ().toLowerCase ());
98
- }
97
+ configValues = Arrays .stream (Quickstart .values ())
98
+ .map (Quickstart ::name )
99
+ .map (String ::toLowerCase )
100
+ .collect (Collectors .toSet ());
99
101
}
100
102
101
103
private final String schemaFilename ;
You can’t perform that action at this time.
0 commit comments