bootstrap_servers –'host[:port]'字符串，或者由'host[:port]'组成的字符串，形如['10.202.24.5:9096', '10.202.24.6:9096', '10.202.24.7:9096'])，其中，host为broker(Broker：缓存代理，Kafka集群中的单台服务器)地址，默认值为 localhost， port默认值为9092，这里可以不用填写所有broker的host和port，但必须保证至少有一个broker）
client_id (str) – 客户端名称，默认值: ‘kafka-python-{version}’
request_timeout_ms (int) – 客户端请求超时时间，单位毫秒。默认值: 30000.
参考API: https://kafka-python.readthedocs.io/en/master/apidoc/KafkaClient.html
brokers()
获取所有broker元数据
available_partitions_for_topic(topic)
返回主题的所有分区
参考API: https://kafka-python.readthedocs.io/en/master/apidoc/ClusterMetadata.html