kafka.conn -> new SaslAuthenticate/SaslHandshake

Author: dpkp

kafka/conn.py

@@ -17,8 +17,7 @@
     infer_broker_version_from_api_versions,
 )
 from kafka.protocol.parser import KafkaProtocol
-from kafka.protocol.sasl_authenticate import SaslAuthenticateRequest
-from kafka.protocol.sasl_handshake import SaslHandshakeRequest
+from kafka.protocol.new.sasl import SaslAuthenticateRequest, SaslHandshakeRequest
 from kafka.protocol.types import Int32
 from kafka.sasl import get_sasl_mechanism
 from kafka.socks5_wrapper import Socks5Wrapper