Bulk consume kafka topic in Python via Apache Arrow python setup.py build_ext --inplace python example.py