kafka2.2源码分析之KafkaChannel

概述 KakfaChannel基本是对SocketChannel的封装,只是这个中间多个一个间接层:TransportLayer,为了封装普通和加密的Channel。TransportLayer子类有PlaintextTransportLayer和SslTransportLayer,分别对应普通和加密的channel。而对于KafkaChannel提供统一的接口,这是策略模式很好的应用。java
相关文章
相关标签/搜索