ZkAclChangeStore Contract

ZkAclChangeStore is the contract of ZkAclChangeStores that FIXME.

package kafka.zk

sealed trait ZkAclChangeStore {
  // only required properties (vals and methods) that have no implementation
  // the others follow
  val aclChangePath: String
  def decode(bytes: Array[Byte]): Resource
  protected def encode(resource: Resource): Array[Byte]
}
Note
 ZkAclChangeStore is a Scala sealed trait and so all the available implementations are in a single compilation unit (i.e. the file with the Scala source code).
Table 1. (Subset of) ZkAclChangeStore Contract
Property Description

aclChangePath

Used when…​FIXME

decode

Used when…​FIXME

encode

Used when…​FIXME
Table 2. ZkAclChangeStores
ZkAclChangeStore Description

ExtendedAclChangeStore

LiteralAclChangeStore

createListener Method

createListener(
  handler: AclChangeNotificationHandler,
  zkClient: KafkaZkClient): AclChangeSubscription

createListener creates a NotificationHandler that simply requests the input AclChangeNotificationHandler to processNotification after decoding the input notification message.

createListener creates a ZkNodeChangeNotificationListener (with the input KafkaZkClient, the aclChangePath, acl_changes_ node prefix and the NotificationHandler).

createListener requests the ZkNodeChangeNotificationListener to init.

In the end, createListener returns a new AclChangeSubscription that requests the ZkNodeChangeNotificationListener to close when requested to close.

Note
 createListener is used when…​FIXME

results matching ""

    No results matching ""