pykafka中consumer_group如何设置

    import logging
    import logger
    from pykafka import KafkaClient
    client = KafkaClient(hosts="**")
    logging.info(client.topics)
    
    input=raw_input('please enter your topic here:')
    topic = client.topics[input]
    
    producer=topic.get_sync_producer()
    while True:
    event = raw_input("Add what to event log?: ('Q' to end.): ")
    if event == 'Q':
        break
    else:
       # msg = event.encode('UTF-8', 'ignore')
    
        producer.produce(event)                                

    import logging
    fr