from __future__ import absolute_import from kafka.oauth.abstract import AbstractTokenProvider