python批量写kafka