Description
I have got this class:
public class CompletePayload { final private int status; final private Map<String, String> headers; final private Object body; }
That is returned by producer:
@Producer public CompletePayload next() { if (!done) { done = true; return client.buildFixedRecord(client.execute(config)); } return null; }
when I retrieve it as a record:
Job.components() // .component("emitter", "REST://Input?" + configStr) // .component("out", "test://collector") // .connections() // .from("emitter") // .to("out") // .build() // .run(); final List<Record> records = handler.getCollectedData(Record.class);