Python Forum
OSError: [WinError 10038] An operation was attempted on something that is not a socke - Printable Version

+- Python Forum (https://python-forum.io)
+-- Forum: Python Coding (https://python-forum.io/forum-7.html)
+--- Forum: Networking (https://python-forum.io/forum-12.html)
+--- Thread: OSError: [WinError 10038] An operation was attempted on something that is not a socke (/thread-10384.html)



OSError: [WinError 10038] An operation was attempted on something that is not a socke - vikas - May-18-2018

Getting Error while sending message using kafka-python producer
OSError: [WinError 10038] An operation was attempted on something that is not a socket
using below code
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]}]) 
Getting below Output

Error:
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