AddMetadataBolt extends AbstractProcessingBolt { @Override protected void process(LogRecord record) { record.addMetadataValue(field, value); }  @Override void configure(Configuration conf);  }
@Test public void testEnrich(@Mocked final LogRecord record) throws Exception { bolt.field = "field"; bolt.value = "value"; new Expectations() {{ record.addMetadataValue(bolt.field, bolt.value); }}; bolt.process(record); }