diff --git a/confluent_client/confluent/asynctlvdata.py b/confluent_client/confluent/asynctlvdata.py
index 8a2656c8..c4630239 100644
--- a/confluent_client/confluent/asynctlvdata.py
+++ b/confluent_client/confluent/asynctlvdata.py
@@ -198,7 +198,7 @@ async def sendall(handle, data):
         cloop = asyncio.get_event_loop()
         return await cloop.sock_sendall(handle, data)
 
- def get_socket(handle):
+def get_socket(handle):
     if isinstance(handle, tuple):
         return handle[1].transport.get_extra_info('socket')
     else: