Skip to content

Connecting to secure kafka error #1539

Closed
@the-sea

Description

@the-sea

error traceback:

Traceback (most recent call last):
  File "/home/apps/pycharm-community-2017.1.5/helpers/pydev/pydevd.py", line 1591, in <module>
    globals = debugger.run(setup['file'], None, None, is_module)
  File "/home/apps/pycharm-community-2017.1.5/helpers/pydev/pydevd.py", line 1018, in run
    pydev_imports.execfile(file, globals, locals)  # execute the script
  File "/home/apps/pycharm-community-2017.1.5/helpers/pydev/_pydev_imps/_pydev_execfile.py", line 18, in execfile
    exec(compile(contents+"\n", file, 'exec'), glob, loc)
  File "/home/projects/pylearn/py_kafka.py", line 40, in <module>
    value_serializer=lambda v: json.dumps(v).encode('utf-8'))
  File "/home/anaconda3/lib/python3.6/site-packages/kafka/producer/kafka.py", line 362, in __init__
    **self.config)
  File "/home/anaconda3/lib/python3.6/site-packages/kafka/client_async.py", line 214, in __init__
    self._bootstrap(collect_hosts(self.config['bootstrap_servers']))
  File "/home/anaconda3/lib/python3.6/site-packages/kafka/client_async.py", line 245, in _bootstrap
    if not bootstrap.connect_blocking():
  File "/home/anaconda3/lib/python3.6/site-packages/kafka/conn.py", line 301, in connect_blocking
    self.connect()
  File "/home/anaconda3/lib/python3.6/site-packages/kafka/conn.py", line 404, in connect
    if self._try_authenticate():
  File "/home/anaconda3/lib/python3.6/site-packages/kafka/conn.py", line 488, in _try_authenticate
    raise ex  # pylint: disable-msg=raising-bad-type
  File "/home/anaconda3/lib/python3.6/site-packages/kafka/conn.py", line 585, in _try_authenticate_gssapi
    output_token = client_ctx.step(received_token)
  File "<decorator-gen-126>", line 2, in step
  File "/home/anaconda3/lib/python3.6/site-packages/gssapi/_utils.py", line 167, in check_last_err
    return func(self, *args, **kwargs)
  File "<decorator-gen-116>", line 2, in step
  File "/home/anaconda3/lib/python3.6/site-packages/gssapi/_utils.py", line 127, in catch_and_return_token
    return func(self, *args, **kwargs)
  File "/home/anaconda3/lib/python3.6/site-packages/gssapi/sec_contexts.py", line 521, in step
    return self._initiator_step(token=token)
  File "/home/anaconda3/lib/python3.6/site-packages/gssapi/sec_contexts.py", line 542, in _initiator_step
    token)
  File "gssapi/raw/sec_contexts.pyx", line 244, in gssapi.raw.sec_contexts.init_sec_context
gssapi.raw.misc.GSSError: Major (851968): Unspecified GSS failure.  Minor code may provide more information, Minor (2529638919): Server kafka/[email protected] not found in Kerberos database

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