all changes done

Author: akshay-ghy

ethereumetl/cli/stream.py

@@ -38,10 +38,10 @@
                    'file://$HOME/Library/Ethereum/geth.ipc or https://mainnet.infura.io')
 @click.option('-o', '--output', type=str,
               help='pubsub or kafka, if empty defaults to printing to console')
-@click.option('-t', '--topic-prefix', type=str,
+@click.option('-t', '--topic-prefix',default='producer-ethereum', type=str,
               help='Google PubSub topic path e.g. projects/your-project/topics/ethereum_blockchain. OR'
                    'Kakfa topic prefix e.g. {chain}-{facet}-{hot/warm}')
-@click.option('-ts', '--topic-suffix', type=str,
+@click.option('-ts', '--topic-suffix',default='hot', type=str,
               help='Google PubSub topic path e.g. projects/your-project/topics/ethereum_blockchain. OR'
                    'Kakfa topic prefix e.g. {chain}-{facet}-{hot/warm}')
 @click.option('-s', '--start-block', default=None, type=int, help='Start block')

setup.py

@@ -38,7 +38,7 @@ def read(fname):
         'eth-abi==1.2.0',
         # TODO: This has to be removed when "ModuleNotFoundError: No module named 'eth_utils.toolz'" is fixed at eth-abi
         'python-dateutil==2.7.0',
-        'click==7.0',
+        'click==8.0',
         'ethereum-dasm'
     ],
     extras_require={

start-hot.sh

@@ -1,3 +1,3 @@
 #!/usr/bin/bash
 source /root/ethereum-etl/env/bin/activate
-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
+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 3 -e transaction,token_transfer,trace -o kafka -t producer-ethereum -ts hot