X-Git-Url: https://osm.etsi.org/gitweb/?p=osm%2Fcommon.git;a=blobdiff_plain;f=osm_common%2Fmsgkafka.py;fp=osm_common%2Fmsgkafka.py;h=5487093b3478c6afc4507de6060436715a68aadc;hp=5caa5b1becb86a78142a4ac50d53596aa64e630e;hb=3dd0db6efaab109fa1bd43395fbbddecf1eb73d4;hpb=3d82ba2cc4c3ebb340a88400aaa4a8d3683806a1 diff --git a/osm_common/msgkafka.py b/osm_common/msgkafka.py index 5caa5b1..5487093 100644 --- a/osm_common/msgkafka.py +++ b/osm_common/msgkafka.py @@ -13,13 +13,14 @@ # 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 , "