File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
src/main/java/io/confluent/connect/jdbc/dialect Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change 2727import io .confluent .connect .jdbc .util .TableDefinition ;
2828import io .confluent .connect .jdbc .util .TableId ;
2929import org .apache .kafka .common .config .AbstractConfig ;
30- import org .apache .kafka .common .utils .Utils ;
3130import org .apache .kafka .connect .data .Date ;
3231import org .apache .kafka .connect .data .Decimal ;
3332import org .apache .kafka .connect .data .Schema ;
4746import java .util .Arrays ;
4847import java .util .Collection ;
4948import java .util .Collections ;
49+ import java .util .HashSet ;
5050import java .util .Map ;
5151import java .util .Set ;
5252import java .util .UUID ;
@@ -83,11 +83,11 @@ public DatabaseDialect create(AbstractConfig config) {
8383 * Define the PG datatypes that require casting upon insert/update statements.
8484 */
8585 private static final Set <String > CAST_TYPES = Collections .unmodifiableSet (
86- Utils . mkSet (
86+ new HashSet <>( Arrays . asList (
8787 JSON_TYPE_NAME ,
8888 JSONB_TYPE_NAME ,
8989 UUID_TYPE_NAME
90- )
90+ ))
9191 );
9292
9393 /**
You can’t perform that action at this time.
0 commit comments