Получение исключения: была предпринята операция с чем-то, что не является сокетом
getting OSError: [WinError 10038
Была предпринята операция с чем-то, что не является сокетом
при отправке сообщения на kafka, используя код ниже
for line_list in a[list with 25k values]:
producer = KafkaProducer(bootstrap_servers=['server'],value_serializer=lambda v: json.dumps(v).encode('utf-8'))
topic = "PYTHON_TOPIC"
producer.send(topic,[{'header':[header_list]},{'Lines':[line_list]}])
ошибка ниже после успешного отправки 4-5 сообщения
Traceback (most recent call last):
File "<ipython-input-11-526ec2ab5244>", line 1, in <module>
runfile('C:/Users/.spyder-py3/untitled16.py', wdir='C:/Users/.spyder-py3')
File "C:\Users\AppData\Local\Continuum\anaconda3\lib\site-packages\spyder\utils\site\sitecustomize.py", line 705, in runfile
execfile(filename, namespace)
File "C:\Users\AppData\Local\Continuum\anaconda3\lib\site-packages\spyder\utils\site\sitecustomize.py", line 102, in execfile
exec(compile(f.read(), filename, 'exec'), namespace)
File "C:/Users/.spyder-py3/untitled16.py", line 90, in <module>
producer = KafkaProducer(bootstrap_servers=['localhost:port'],value_serializer=lambda v: json.dumps(v).encode('utf-8'))
File "C:\Users\AppData\Local\Continuum\anaconda3\lib\site-packages\kafka\producer\kafka.py", line 362, in __init__
**self.config) File "C:\Users\AppData\Local\Continuum\anaconda3\lib\site-packages\kafka\client_async.py", line 219, in __init__
self.config['api_version'] = self.check_version(timeout=check_timeout)
File "C:\Users\AppData\Local\Continuum\anaconda3\lib\site-packages\kafka\client_async.py", line 828, in check_version
version = conn.check_version(timeout=remaining, strict=strict)
File "C:\Users\AppData\Local\Continuum\anaconda3\lib\site-packages\kafka\conn.py", line 954, in check_version
selector.select(1)
File "C:\Users\AppData\Local\Continuum\anaconda3\lib\selectors.py", line 323, in select
r, w, _ = self._select(self._readers, self._writers, [], timeout)
File "C:\Users\AppData\Local\Continuum\anaconda3\lib\selectors.py", line 314, in _select
r, w, x = select.select(r, w, w, timeout)
OSError: [WinError 10038] An operation was attempted on something that is not a socket