Fixed file name typo and used exporters

Author: ayush3298

blockchainetl/jobs/exporters/kafka_expoerter.py blockchainetl/jobs/exporters/kafka_exporter.py

@@ -59,7 +59,6 @@ def stream(last_synced_block_file, lag, provider_uri, output, start_block, entit
     entity_types = parse_entity_types(entity_types)
     validate_entity_types(entity_types, output)
 
-    from ethereumetl.streaming.item_exporter_creator import create_item_exporter
     from ethereumetl.streaming.eth_streamer_adapter import EthStreamerAdapter
     from blockchainetl.streaming.streamer import Streamer
 
@@ -69,7 +68,7 @@ def stream(last_synced_block_file, lag, provider_uri, output, start_block, entit
 
     streamer_adapter = EthStreamerAdapter(
         batch_web3_provider=ThreadLocalProxy(lambda: get_provider_from_uri(provider_uri, batch=True)),
-        item_exporter=create_item_exporter(output),
+        item_exporter=create_item_exporters(output),
         batch_size=batch_size,
         max_workers=max_workers,
         entity_types=entity_types

ethereumetl/cli/stream.py

@@ -76,7 +76,7 @@ def create_item_exporter(output):
     elif item_exporter_type == ItemExporterType.CONSOLE:
         item_exporter = ConsoleItemExporter()
     elif item_exporter_type == ItemExporterType.KAFKA:
-        from blockchainetl.jobs.exporters.kafka_expoerter import KafkaItemExporter
+        from blockchainetl.jobs.exporters.kafka_exporter import KafkaItemExporter
         item_exporter = KafkaItemExporter(output, item_type_to_topic_mapping={
             'block': 'blocks',
             'transaction': 'transactions',