kafka producer for gdax api

gdax_producer.py

import gdax
class OrderBookProducer(gdax.WebsocketClient):
    def on_open(self):
        self.products = ["ETH-BTC"]
        self.channels = ["level2"]
    def on_message(self, msg):
        if msg['type'] == 'snapshot':
            print(msg)
    def on_close(self):
        print("-- Goodbye! --")