NotificationHandler
is the contract of change notification handlers that can process change notifications.
package kafka.common
trait NotificationHandler {
def processNotification(notificationMessage: Array[Byte])
}
Property | Description |
---|---|
|
Used exclusively when |
NotificationHandler | Description |
---|---|