Fixing the bug of producer becomming null
@@ -31,7 +31,7 @@ public class ParsingTriggeringTask extends AiravataTask {
props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG,
StringSerializer.class.getName());
props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, ProcessCompletionMessageSerializer.class.getName());
- this.producer = producer;
+ this.producer = new KafkaProducer<String, ProcessCompletionMessage>(props);;
}
public void submitMessageToParserEngine(ProcessCompletionMessage completionMessage) throws ExecutionException, InterruptedException, ApplicationSettingsException {
