Can you help recommend a Task Queue Library in Python which uses Kafka?

I understand Celery/RabbitMQ is defacto standard when it comes to Python, but with Kafka becoming more and more efficient, it would be better to adapt to Kafka.

Any suggestions.