TopicOperator { Future<Void> onTopicDeleted(LogContext logContext, TopicName topicName) { return executeWithTopicLockHeld(logContext, topicName, new Reconciliation("onTopicDeleted") { @Override public Future<Void> execute() { return reconcileOnTopicChange(logContext, topicName, null, this); } }); } TopicOperator(Vertx vertx, Kafka kafka,
                         K8s k8s,
                         TopicStore topicStore,
                         Labels labels,
                         String namespace,
                         Config config,
                         MetricsProvider metrics); void initMetrics(); Counter getPeriodicReconciliationsCounter(); void setTopicCount(int topics); Future<Void> executeWithTopicLockHeld(LogContext logContext, TopicName key, Reconciliation action); boolean isWorkInflight(); static final String METRICS_PREFIX; }
@Test public void testOnTopicDeleted(VertxTestContext context) { Exception storeException = null; Exception k8sException = null; topicDeleted(context, storeException, k8sException); }