class BaseTask implements InitableTask, StreamTask, ClosableTask {

    protected GenericData.Record getCamusHeaders(GenericRecord eventHeaders, Schema headerSchema, long tsNow) {
        GenericRecordBuilder builder = new GenericRecordBuilder(headerSchema);
        if (headerSchema.getField("created") != null) {
            builder.set("created", tsNow);
        }
        copyCamusTimestamp(eventHeaders, headerSchema, builder);
        copyAvroField(eventHeaders, headerSchema, builder, "id");
        return builder.build();
    }

}