上一篇写的1个topic，今天发现，我会有多个主题怎么办呢 ，找来找去，终于找到这个代码了 。
#!/usr/bin/python
# encoding=utf-8
from kafka import KafkaConsumer
print('start consumer')
consumer = KafkaConsumer(
bootstrap_servers="kafka-zookeeper-01:9092", # kafka集群地址
# value_serializer=lambda v: json.dumps(v).encode('utf-8')
# group_id = "my.group", # 消费组id
# enable_auto_commit = True, # 每过一段时间自动提交所有已消费的消息（在迭代时提交）
# auto_commit_interval_ms = 5000, # 自动提交的周期（毫秒）
)
consumer.subscribe(['topic1', 'topic2']) # 消费者订阅多个topic
for message in consumer:
print(message.topic, message.value) # 这样就可以通过topic和value去做后边的操作了
print('end consumer')
