Python Forum
OSError: [WinError 10038] An operation was attempted on something that is not a socke
Thread Rating:
  • 2 Vote(s) - 2.5 Average
  • 1
  • 2
  • 3
  • 4
  • 5
OSError: [WinError 10038] An operation was attempted on something that is not a socke
#1
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
Reply


Possibly Related Threads…
Thread Author Replies Views Last Post
  [WinError 10057] lolloiltizio 0 4,905 Aug-10-2020, 05:57 PM
Last Post: lolloiltizio
  Server and Network (socket) [WinError 10053] Timxxx 1 4,536 Aug-23-2019, 10:03 AM
Last Post: iMuny
  Server and Network (socket) [WinError 10053] SheeppOSU 2 22,172 Apr-13-2019, 09:23 PM
Last Post: SheeppOSU

Forum Jump:

User Panel Messages

Announcements
Announcement #1 8/1/2020
Announcement #2 8/2/2020
Announcement #3 8/6/2020