# See the License for the specific language governing permissions and
# limitations under the License.
-import logging
import asyncio
-import yaml
+import logging
+
from aiokafka import AIOKafkaConsumer
from aiokafka import AIOKafkaProducer
from aiokafka.errors import KafkaError
from osm_common.msgbase import MsgBase, MsgException
+import yaml
__author__ = (
"Alfonso Tierno <alfonso.tiernosepulveda@telefonica.com>, "