BrokerConnection

final public class BrokerConnection : BrokerConnectionProtocol

The BrokerConnection is a connection to one specific broker in the Kafka cluster. It owns the NIO Channel with the underlying TCP connecting and offers a high level interface to send messages to the broker.

  • Logger for the broker connection

    Declaration

    Swift

    public let logger: Logger