Skip to content

Socket disconnect during SASLHandShakeRequest #1288

Closed
@natedogs911

Description

@natedogs911

I'm using SASL_SSL with GSSAPI,
I've added some prints just show where the disconnect is occurring.

I'm using the latest version, 34dc9dd

<BrokerConnection node_id=bootstrap host=kafkabroker.somewhere.com/kafkabroker.somewhere.com port=9093>: creating new socket
<BrokerConnection node_id=bootstrap host=kafkabroker.somewhere.com/10.10.10.1 port=9093>: setting socket option (6, 1, 1)
<BrokerConnection node_id=bootstrap host=kafkabroker.somewhere.com/10.10.10.1 port=9093>: wrapping socket in ssl context
<BrokerConnection node_id=bootstrap host=kafkabroker.somewhere.com/10.10.10.1 port=9093>: connecting to 10.10.10.1:9093
<BrokerConnection node_id=bootstrap host=kafkabroker.somewhere.com/10.10.10.1 port=9093>: established TCP connection
<BrokerConnection node_id=bootstrap host=kafkabroker.somewhere.com/10.10.10.1 port=9093>: initiating SSL handshake
<BrokerConnection node_id=bootstrap host=kafkabroker.somewhere.com/10.10.10.1 port=9093>: completed SSL handshake.
<BrokerConnection node_id=bootstrap host=kafkabroker.somewhere.com/10.10.10.1 port=9093>: initiating SASL authentication
here at _try_authenticate(self)
self._sasl_auth_future is None
def _send
Sending request SaslHandShakeRequest_v0(mechanism='GSSAPI')
try in _send
<BrokerConnection node_id=bootstrap host=kafkabroker.somewhere.com/10.10.10.1 port=9093> Request 1: SaslHandShakeRequest_v0(mechanism='GSSAPI')
begin in def recv
before self._recv()
here at _try_authenticate(self)
begin in def recv
before self._recv()
here at _try_authenticate(self)
begin in def recv
before self._recv()
here at _try_authenticate(self)
begin in def recv
before self._recv()
<BrokerConnection node_id=bootstrap host=kafkabroker.somewhere.com/10.10.10.1 port=9093>: socket disconnected
<BrokerConnection node_id=bootstrap host=kafkabroker.somewhere.com/10.10.10.1 port=9093>: Closing connection. ConnectionError: socket disconnected
<BrokerConnection node_id=bootstrap host=kafkabroker.somewhere.com/10.10.10.1 port=9093>: reconnect backoff 0.05920430114698077 after 1 failures
nate: before return false after sasl auth future is none
Unable to bootstrap from [('kafkabroker.somewhere.com', 9093, <AddressFamily.AF_UNSPEC: 0>)]

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions