use kafka python lib for consumer in test