python - PyKafka API の使用

Question

私は Kafka と PyKafka の初心者です。以下のコードを使用して PyKafka でプロデューサーとコンシューマーが作成されることを知っています。

from pykafka import KafkaClient
client = KafkaClient("localhost:9092")

topic = client.topics["topicname"]
producer = topic.get_producer()
consumer = topic.get_simple_consumer()

KafkaClient とは何か、プロデューサーとコンシューマーの作成にどのように役立つかを知りたいです。

client.clusterと を使用してクラスターとブローカーを作成できることを読みましclient.brokerたが、ここでの使用を理解できませんclient。