style: fix whitespaces
This commit is contained in:
committed by
David Arthur
parent
f833050f0a
commit
e87cddef1b
@@ -22,7 +22,7 @@ class KafkaClient(object):
|
||||
|
||||
def __init__(self, host, port, bufsize=4096, client_id=CLIENT_ID):
|
||||
# We need one connection to bootstrap
|
||||
self.bufsize = bufsize
|
||||
self.bufsize = bufsize
|
||||
self.client_id = client_id
|
||||
self.conns = { # (host, port) -> KafkaConnection
|
||||
(host, port): KafkaConnection(host, port, bufsize)
|
||||
|
||||
@@ -69,14 +69,18 @@ class ErrorMapping(object):
|
||||
# Exceptions #
|
||||
#################
|
||||
|
||||
|
||||
class BufferUnderflowError(Exception):
|
||||
pass
|
||||
|
||||
|
||||
class ChecksumError(Exception):
|
||||
pass
|
||||
|
||||
|
||||
class ConsumerFetchSizeTooSmall(Exception):
|
||||
pass
|
||||
|
||||
|
||||
class ConsumerNoMoreData(Exception):
|
||||
pass
|
||||
|
||||
@@ -3,8 +3,10 @@ import socket
|
||||
import struct
|
||||
from threading import local
|
||||
|
||||
|
||||
log = logging.getLogger("kafka")
|
||||
|
||||
|
||||
class KafkaConnection(local):
|
||||
"""
|
||||
A socket connection to a single Kafka broker
|
||||
|
||||
Reference in New Issue
Block a user