カフカとPython

Question

私はAPIのURLからデータを取得するPythonコードを持って

def get_api_request(zipcode): 
    request_url = 'https://www.zipcodeapi.com/rest/<apikey>/info.json/'+ str(zipcode)+'/degrees' 
    request = Request(request_url) 

    try: 
     response = urlopen(request) 
     data = response.read() 
     data = json.loads(data) 
     city=data['city'] 
     state=data['state'] 
     update_city(city,state) 

    except (Exception) as error: 
      print(error) 

上記のコードは、基本的には、与えられた郵便番号のための都市と状態を取得します。カフカを初めて知っている私は、カフカを通じてこの同じプロセスを実装しようとしています（大きなデータセットを管理するため）。

Kafkaの仕組みを理解するために、上記のコードを変更してKafkaの実装を含めることができますか？

Answer 1

あなたは、既存のREST APIではなく、カフカのトピックからメッセージを読むことについて話しています。

https://www.confluent.io/blog/introduction-to-apache-kafka-for-python-programmers/とhttps://github.com/confluentinc/confluent-kafka-pythonを確認してください。