{"action":"created","issue":{"url":"https://api.github.com/repos/dpkp/kafka-python/issues/1259","repository_url":"https://api.github.com/repos/dpkp/kafka-python","labels_url":"https://api.github.com/repos/dpkp/kafka-python/issues/1259/labels{/name}","comments_url":"https://api.github.com/repos/dpkp/kafka-python/issues/1259/comments","events_url":"https://api.github.com/repos/dpkp/kafka-python/issues/1259/events","html_url":"https://github.com/dpkp/kafka-python/issues/1259","id":265680198,"number":1259,"title":"Can not connect with SASL_PLAINTEX and GSSAPI: kafka.future:Error processing callback","user":{"login":"gm9794","id":32745616,"avatar_url":"https://avatars3.githubusercontent.com/u/32745616?v=4","gravatar_id":"","url":"https://api.github.com/users/gm9794","html_url":"https://github.com/gm9794","followers_url":"https://api.github.com/users/gm9794/followers","following_url":"https://api.github.com/users/gm9794/following{/other_user}","gists_url":"https://api.github.com/users/gm9794/gists{/gist_id}","starred_url":"https://api.github.com/users/gm9794/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/gm9794/subscriptions","organizations_url":"https://api.github.com/users/gm9794/orgs","repos_url":"https://api.github.com/users/gm9794/repos","events_url":"https://api.github.com/users/gm9794/events{/privacy}","received_events_url":"https://api.github.com/users/gm9794/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":1,"created_at":"2017-10-16T08:08:36Z","updated_at":"2017-10-17T04:34:13Z","closed_at":null,"author_association":"NONE","body":"Hi,\r\n\r\nfollowing the #1255 and its fix provided in #1257, we can move a few steps ahead, but another error appears (see log below).\r\n\r\nThanks.\r\n\r\n```\r\n>>> consumer = KafkaConsumer('test1'\r\n...                          ,bootstrap_servers=['kafka1-lab.company.com:6667']\r\n...                          ,api_version=(0,10,0)\r\n...                          ,group_id='python_client'\r\n...                          ,security_protocol='SASL_PLAINTEXT'\r\n...                          ,sasl_mechanism='GSSAPI')\r\nDEBUG:kafka.metrics.metrics:Added sensor with name connections-closed\r\nDEBUG:kafka.metrics.metrics:Added sensor with name connections-created\r\nDEBUG:kafka.metrics.metrics:Added sensor with name select-time\r\nDEBUG:kafka.metrics.metrics:Added sensor with name io-time\r\nINFO:kafka.client:Bootstrapping cluster metadata from [('kafka1-lab.company.com', 6667, <AddressFamily.AF_UNSPEC: 0>)]\r\nDEBUG:kafka.client:Attempting to bootstrap via node at kafka1-lab.company.com:6667\r\nDEBUG:kafka.metrics.metrics:Added sensor with name bytes-sent-received\r\nDEBUG:kafka.metrics.metrics:Added sensor with name bytes-sent\r\nDEBUG:kafka.metrics.metrics:Added sensor with name bytes-received\r\nDEBUG:kafka.metrics.metrics:Added sensor with name request-latency\r\nDEBUG:kafka.metrics.metrics:Added sensor with name node-bootstrap.bytes-sent\r\nDEBUG:kafka.metrics.metrics:Added sensor with name node-bootstrap.bytes-received\r\nDEBUG:kafka.metrics.metrics:Added sensor with name node-bootstrap.latency\r\nDEBUG:kafka.conn:<BrokerConnection node_id=bootstrap host=kafka1-lab.company.com/kafka1-lab.company.com port=6667>: creating new socket\r\nDEBUG:kafka.conn:<BrokerConnection node_id=bootstrap host=kafka1-lab.company.com/10.24.28.27 port=6667>: setting socket option (6, 1, 1)\r\nINFO:kafka.conn:<BrokerConnection node_id=bootstrap host=kafka1-lab.company.com/10.24.28.27 port=6667>: connecting to 10.24.28.27:6667\r\nDEBUG:kafka.conn:<BrokerConnection node_id=bootstrap host=kafka1-lab.company.com/10.24.28.27 port=6667>: established TCP connection\r\nDEBUG:kafka.conn:<BrokerConnection node_id=bootstrap host=kafka1-lab.company.com/10.24.28.27 port=6667>: initiating SASL authentication\r\nDEBUG:kafka.protocol.parser:Sending request SaslHandShakeRequest_v0(mechanism='GSSAPI')\r\nDEBUG:kafka.conn:<BrokerConnection node_id=bootstrap host=kafka1-lab.company.com/10.24.28.27 port=6667> Request 1: SaslHandShakeRequest_v0(mechanism='GSSAPI')\r\nDEBUG:kafka.protocol.parser:Received correlation id: 1\r\nDEBUG:kafka.protocol.parser:Processing response SaslHandShakeResponse_v0\r\nDEBUG:kafka.conn:<BrokerConnection node_id=bootstrap host=kafka1-lab.company.com/10.24.28.27 port=6667> Response 1: SaslHandShakeResponse_v0(error_code=0, enabled_mechanisms=['GSSAPI'])\r\nDEBUG:kafka.conn:<BrokerConnection node_id=bootstrap host=kafka1-lab.company.com/10.24.28.27 port=6667>: canonical Servicename: kafka/serv888350.company.com@COMPANY.COM\r\nERROR:kafka.future:Error processing callback\r\nTraceback (most recent call last):\r\n  File \"/opt/continuum/anaconda3/lib/python3.6/site-packages/kafka/future.py\", line 79, in _call_backs\r\n    f(value)\r\n  File \"/opt/continuum/anaconda3/lib/python3.6/site-packages/kafka/conn.py\", line 471, in _handle_sasl_handshake_response\r\n    return self._try_authenticate_gssapi(future)\r\n  File \"/opt/continuum/anaconda3/lib/python3.6/site-packages/kafka/conn.py\", line 541, in _try_authenticate_gssapi\r\n    log.debug(\"%s: initiator name: %s\", self, ctx_Context.initiator_name)\r\n  File \"/opt/continuum/anaconda3/lib/python3.6/site-packages/gssapi/_utils.py\", line 64, in inquire_property\r\n    raise AttributeError(msg)\r\nAttributeError: Cannot read {0} from a security context whose establishment has not yet been started.\r\nWARNING:kafka.conn:<BrokerConnection node_id=bootstrap host=kafka1-lab.company.com/10.24.28.27 port=6667>: No in-flight-requests to recv\r\nWARNING:kafka.conn:<BrokerConnection node_id=bootstrap host=kafka1-lab.company.com/10.24.28.27 port=6667>: No in-flight-requests to recv\r\nWARNING:kafka.conn:<BrokerConnection node_id=bootstrap host=kafka1-lab.company.com/10.24.28.27 port=6667>: No in-flight-requests to recv\r\nWARNING:kafka.conn:<BrokerConnection node_id=bootstrap host=kafka1-lab.company.com/10.24.28.27 port=6667>: No in-flight-requests to recv\r\n\r\n```"},"comment":{"url":"https://api.github.com/repos/dpkp/kafka-python/issues/comments/337115240","html_url":"https://github.com/dpkp/kafka-python/issues/1259#issuecomment-337115240","issue_url":"https://api.github.com/repos/dpkp/kafka-python/issues/1259","id":337115240,"user":{"login":"natedogs911","id":12566291,"avatar_url":"https://avatars2.githubusercontent.com/u/12566291?v=4","gravatar_id":"","url":"https://api.github.com/users/natedogs911","html_url":"https://github.com/natedogs911","followers_url":"https://api.github.com/users/natedogs911/followers","following_url":"https://api.github.com/users/natedogs911/following{/other_user}","gists_url":"https://api.github.com/users/natedogs911/gists{/gist_id}","starred_url":"https://api.github.com/users/natedogs911/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/natedogs911/subscriptions","organizations_url":"https://api.github.com/users/natedogs911/orgs","repos_url":"https://api.github.com/users/natedogs911/repos","events_url":"https://api.github.com/users/natedogs911/events{/privacy}","received_events_url":"https://api.github.com/users/natedogs911/received_events","type":"User","site_admin":false},"created_at":"2017-10-17T04:34:13Z","updated_at":"2017-10-17T04:34:13Z","author_association":"NONE","body":"I'm still unable to bootstrap, Is there something that I can do to help debug the connection?\r\nI'm going to work on parsing the logs in the mean time"}}
{"actor":{"display_login":"natedogs911"}}