Support librdkafka in the ManagedBalancedConsumer

[waytai]

Traceback (most recent call last):                                                                          
  File "pyconsume.py", line 30, in <module>                                                                 
    use_rdkafka = True                                                                                      
  File "/usr/local/lib/python2.7/dist-packages/pykafka/topic.py", line 214, in get_balanced_consumer        
    return cls(self, self._cluster, consumer_group, **kwargs)                                               
  File "/usr/local/lib/python2.7/dist-packages/pykafka/managedbalancedconsumer.py", line 188, in __init__   
    self.__class__.__name__))                                                                               
ImportError: use_rdkafka is not available for ManagedBalancedConsumer                                       
Exception AttributeError: "'ManagedBalancedConsumer' object has no attribute '_running'" in <bound method Ma
nagedBalancedConsumer.__del__ of <pykafka.managedbalancedconsumer.ManagedBalancedConsumer at 0x7f5a65a31b10 
(consumer_group=KAFKA_01)>> ignored

[emmettbutler]

At the time the ManagedBalancedConsumer was written, librdkafka didn't support Kafka-managed consumer groups, so this ImportError was added to make that clear. We should reexamine where librdkafka's support is these days, and fix this if possible. This will probably happen during Parse.ly's internal upgrade to latest Kafka later this year.

[waytai]

than you for your kindly reply

[razor-1]

seems like confluentinc/librdkafka#601 (comment) indicates some of how this works, and the issue overall explains that librdkafka supports this now, if I'm reading it correctly