You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by GitBox <gi...@apache.org> on 2021/06/08 03:46:28 UTC

[GitHub] [kafka] showuon commented on a change in pull request #10838: MINOR: Refactor DynamicConfigManager

showuon commented on a change in pull request #10838:
URL: https://github.com/apache/kafka/pull/10838#discussion_r647088430



##########
File path: core/src/main/scala/kafka/server/DynamicConfigManager.scala
##########
@@ -71,9 +71,11 @@ object ConfigEntityName {
  *
  * This will fire a watcher on all brokers. This watcher works as follows. It reads all the config change notifications.
  * It keeps track of the highest config change suffix number it has applied previously. For any previously applied change it finds
- * it checks if this notification is larger than a static expiration time (say 10mins) and if so it deletes this notification.
+ * it checks if this notification is larger than a static expiration time (default to 15 mins) and if so it deletes this notification.
  * For any new changes it reads the new configuration, combines it with the defaults, and updates the existing config.
  *
+ * See [[kafka.common.ZkNodeChangeNotificationListener]] for details

Review comment:
       In https://github.com/apache/kafka/pull/679, we make DynamicConfigManager to use the ZkNodeChangeNotificationListener. Add a link here.




-- 
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.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org