使用Python連接kafka獲取topic里的消息

from kafka import KafkaConsumer  #導入第三方庫
import time
from log.log import logger

#  與kafka建立連接
consumer = KafkaConsumer('kafka-topic',bootstrap_servers=['ip:9092'])
print("連接成功")
for message in consumer:   #開始消費消息
    logger.info("%s value=%s" %(message.topic,message.value))
    print ("%s %s value=%s" % (time.strftime('%Y-%m-%d %H:%M:%S', time.localtime(time.time())),message.topic,message.value))