NotificationHandler Contract

NotificationHandler is the contract of change notification handlers that can process change notifications.

package kafka.common

trait NotificationHandler {
  def processNotification(notificationMessage: Array[Byte])
}
Table 1. NotificationHandler Contract
Property Description

processNotification

Handles a change notification

Used exclusively when ZkNodeChangeNotificationListener is requested to processNotification
Table 2. NotificationHandlers
NotificationHandler Description

rawHandler

ConfigChangedNotificationHandler

TokenChangedNotificationHandler

results matching ""

    No results matching ""