kafka2.2源碼分析之KafkaChannel

概述 KakfaChannel基本是對SocketChannel的封裝,只是這個中間多個一個間接層:TransportLayer,爲了封裝普通和加密的Channel。TransportLayer子類有PlaintextTransportLayer和SslTransportLayer,分別對應普通和加密的channel。而對於KafkaChannel提供統一的接口,這是策略模式很好的應用。java
相關文章
相關標籤/搜索