add kafka to setup

Author: akshay-ghy

setup.py

@@ -44,7 +44,8 @@ def read(fname):
     extras_require={
         'streaming': [
             'timeout-decorator==0.4.1',
-            'google-cloud-pubsub==0.39.1'
+            'google-cloud-pubsub==0.39.1',
+            'confluent-kafka==2.2.0'
         ],
         'dev': [
             'pytest~=4.3.0'

start-hot.sh

@@ -1,3 +1,3 @@
 #!/usr/bin/bash
 source /root/ethereum-etl/env/bin/activate
-python /root/ethereum-etl/ethereumetl.py stream --provider-uri $ETHEREUM_PROVIDER_URI -w 5 -B 3 -b 3 --period-seconds 2 -l /root/ethereum-etl/last_synced_block_hot.txt --lag 0 -e transaction,token_transfer,trace -o kafka -t producer-ethereum - ts hot
+ethereumetl stream --provider-uri $ETHEREUM_PROVIDER_URI -w 5 -B 3 -b 3 --period-seconds 2 -l /root/ethereum-etl/last_synced_block_hot.txt --lag 0 -e transaction,token_transfer,trace -o kafka -t producer-ethereum -ts hot