- ConsumerStatusInfo request = gson.fromJson(requestBody, ConsumerStatusInfo.class);
- log.info("Add Status Job Info", request);
+ JobDataSchema request = gson.fromJson(requestBody, JobDataSchema.class);
+ log.debug("Body Received: {}" , requestBody);
+ try {
+ this.jobs.addJob(request.getInfo_type_id(), types.getType(request.getInfo_type_id()), "",
+ new Parameters(new KafkaDeliveryInfo(
+ request.getJob_data_schema().getTopic(),
+ request.getJob_data_schema().getBootStrapServers(), 0)));
+ } catch (Exception e) {
+ log.error("Error adding the info type " + request.getInfo_type_id() + "{}", e.getMessage());
+ }