buildRecordWithSchema.java

buildRecordWithSchema.java

private static GenericRecord buildRecord(LoginAttackCount loginAttackCount) throws IOException {
    // avro schema avsc file path.
    String schemaPath = "src/main/java/loginStream/login-attack-count.avsc";

    String schemaString;

    try (FileInputStream inputStream = new FileInputStream(schemaPath)) {
        schemaString = org.apache.commons.io.IOUtils.toString(inputStream);
    } catch (Exception e) {
        throw new RuntimeException(e);
    }
    Schema schema = new Schema.Parser().parse(schemaString);
    GenericData.Record record = new GenericData.Record(schema);
    // put the elements according to the avro schema.
    record.put("userName", loginAttackCount.userName);
    record.put("counter", loginAttackCount.counter);
    record.put("to", loginAttackCount.to);
    record.put("start", loginAttackCount.start);

    return record;
}