EndPoint

EndPoint is a data structure that represents an endpoint of a Kafka broker using the following properties:

  • Host

  • Port

  • ListenerName

  • SecurityProtocol

EndPoint is created when:

EndPoint is used when:

connectionString Method

connectionString: String

connectionString…​FIXME

Note
 connectionString is used when…​FIXME

Creating EndPoint — createEndPoint Utility

createEndPoint(
  connectionString: String,
  securityProtocolMap: Option[Map[ListenerName, SecurityProtocol]]): EndPoint

createEndPoint…​FIXME

Note

createEndPoint is used when:

results matching ""

    No results matching ""