CoreUtils Utility

CoreUtils comes with the following utilities:

Converting Listener Names to EndPoints — listenerListToEndPoints Utility

listenerListToEndPoints(
  listeners: String,
  securityProtocolMap: Map[ListenerName, SecurityProtocol]): Seq[EndPoint]

listenerListToEndPoints…​FIXME

Note
 listenerListToEndPoints is used when KafkaConfig is requested for the listeners and advertisedListeners

results matching ""

    No results matching ""