From 9a33d4db0e7ad44ee2c546091bce53f95f44f042 Mon Sep 17 00:00:00 2001 From: orfeas0 Date: Wed, 23 May 2018 18:05:05 +0300 Subject: [PATCH] create self.batch_size attribute Is needed when the handler is being called. --- src/KafkaHandler.py | 1 + 1 file changed, 1 insertion(+) diff --git a/src/KafkaHandler.py b/src/KafkaHandler.py index bb16b6b..002ae89 100644 --- a/src/KafkaHandler.py +++ b/src/KafkaHandler.py @@ -13,6 +13,7 @@ def __init__(self, backup_file, hosts_list, topic, batch_size): logging.Handler.__init__(self) # Backup log file for errors self.fail_fh = open(backup_file, 'w') + self.batch_size = batch_size kafka_client = KafkaClient(hosts_list) topic = kafka_client.topics[topic] self.key = bytes(str(socket.gethostname()))