Update default topic name: CallableIndexExtension
Extension was renamed from `GraphDBExtension` to `CallableIndexExtension` in commit so adjusting the default consume Kafka topic name from `fasten.GraphDBExtension.out` to `fasten.CallableIndexExtension.out`
@@ -52,7 +52,7 @@ public class VulnerabilityCacheInvalidationPlugin extends Plugin {
private final Logger logger = LoggerFactory.getLogger(VulnerabilityCacheInvalidationExtension.class.getName());
- private String consumerTopic = "fasten.GraphDBExtension.out";
+ private String consumerTopic = "fasten.CallableIndexExtension.out";
private static GraphMavenResolver graphResolver;
private static String baseDir;
@@ -157,7 +157,7 @@ public class VulnerabilityCacheInvalidationPlugin extends Plugin {
this.depSet = null;
this.setPluginError(null);
- // Parse JSON object from kafka topic of GraphDBExtension.
+ // Parse JSON object from kafka topic of CallableIndexExtension.
// Although it doesn't have output payload, the plugin serializes the graph for its input.
// And we can use the input copy from this topic and the serialized graph to process our caching.
var json = new JSONObject(record);
