Skip to content

ZkNodeChangeNotificationListener

Creating Instance

ZkNodeChangeNotificationListener takes the following to be created:

  • KafkaZkClient
  • Node Root
  • Node Prefix
  • NotificationHandler
  • Change Expiration (in millis, default: 15 * 60 * 1000)
  • Time

ZkNodeChangeNotificationListener is created when:

  • DelegationTokenManager is requested to startup
  • ZkConfigManager is created
  • ZkAclChangeStore is requested to createListener