noojung commented on code in PR #23567:
URL: https://github.com/apache/kafka/pull/23567#discussion_r4098202530
##########
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerder.java:
##########
@@ -185,6 +185,7 @@ public synchronized void deleteConnectorConfig(String
connName, Callback<Created
worker.stopAndAwaitConnector(connName);
configBackingStore.removeConnectorConfig(connName);
onDeletion(connName);
+ resetConnectorActiveTopics(connName);
Review Comment:
The reset is effectively a no-op in standalone mode when topic tracking is
disabled, since no active topics are recorded, but I've added the check for
consistency with distributed mode.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
