broker version log info

Author: dpkp

kafka/conn.py

@@ -597,6 +597,7 @@ def _handle_api_versions_response(self, future, response):
             for api_key, min_version, max_version in response.api_versions
         ])
         self._api_version = self._infer_broker_version_from_api_versions(self._api_versions)
+        log.info('Broker version identified as %s', '.'.join(map(str, version)))
         future.success(self._api_version)
         self.connect()
 
@@ -607,8 +608,8 @@ def _handle_api_versions_failure(self, future, ex):
 
     def _handle_check_version_response(self, future, version, _response):
         log.info('Broker version identified as %s', '.'.join(map(str, version)))
-        #log.info('Set configuration api_version=%s to skip auto'
-        #         ' check_version requests on startup', version)
+        log.info('Set configuration api_version=%s to skip auto'
+                 ' check_version requests on startup', version)
         self._api_versions = BROKER_API_VERSIONS[version]
         self._api_version = version
         future.success(version)