reset pluginError for vuln_consumer on consume
@@ -76,6 +76,8 @@ public class VulnerabilityConsumer extends Plugin {
public void consume(String record) {
// Step 1: Parse the record to a Vulnerability Object
try {
+ // Reset plugin error
+ this.pluginError = null;
var v = objectMapper.readValue(record, Vulnerability.class);
logger.info("Read vulnerability " + v.getId() + " from Kafka");
// Step 2: Store the vulnerability object in the DB using the MetadataUtility
