protected Function<Object[],Object> createKeyGenerator(Schema schema,TableId columnSetName,List<Column> columns){
  if (schema != null) {
    int[] recordIndexes=indexesForColumns(columns);
    Field[] fields=fieldsForColumns(schema,columns);
    int numFields=recordIndexes.length;
    ValueConverter[] converters=convertersForColumns(schema,columnSetName,columns,null,null);
    return null;
  }
  return null;
}

protected Function < Object [ ] , Object > createKeyGenerator ( Schema schema , TableId columnSetName , List < Column > columns ) { if ( schema != null ) { int [ ] recordIndexes = indexesForColumns ( columns ) ; Field [ ] fields = fieldsForColumns ( schema , columns ) ; int numFields = recordIndexes . length ; ValueConverter [ ] converters = convertersForColumns ( schema , columnSetName , columns , null , null ) ; return null ; } return null ; }
creates the function that produces a kafka connect key object for a row of data .
