consumer#!/usr/bin/env python# -*- coding: utf-8 -*-# @author: yangyue# pip install kafkafrom kafka import KafkaProducerfrom kafka import KafkaConsumerfrom kafka.errors import KafkaErrorclass Kaf