pykafka.utils.socket

Author: Keith Bourgoin, Emmett Butler

pykafka.utils.socket.recvall_into(socket, bytea, size)

Reads size bytes from the socket into the provided bytearray (modifies in-place.)

This is basically a hack around the fact that socket.recv_into doesn’t allow buffer offsets.

Return type:bytearray