commit 10602af49b01f0370761e913eacf485e77e4fde0
author tierno <alfonso.tiernosepulveda@telefonica.com> Mon Feb 18 14:53:54 2019 +0000
committer tierno <alfonso.tiernosepulveda@telefonica.com> Mon Feb 18 14:54:00 2019 +0000
tree 86e29cb7b59e84daf0da9b593da3fa1e784a42b3
parent bd5a4020099f419c5a54a7c2d8de0b6f1b90b9cc

allow set/unset group_id at kafka message consumer

Change-Id: I138cb29b012536473f6aea21975b06013e84e043
Signed-off-by: tierno <alfonso.tiernosepulveda@telefonica.com>

osm_common/msgbase.py

diff --git a/osm_common/msgbase.py b/osm_common/msgbase.py
index 92b24e0..7c27f64 100644
--- a/osm_common/msgbase.py
+++ b/osm_common/msgbase.py
@@ -77,5 +77,5 @@
     async def aiowrite(self, topic, key, msg, loop=None):
         raise MsgException("Method 'aiowrite' not implemented", http_code=HTTPStatus.INTERNAL_SERVER_ERROR)
 
-    async def aioread(self, topic, loop=None, callback=None, aiocallback=None, **kwargs):
+    async def aioread(self, topic, loop=None, callback=None, aiocallback=None, group_id=None, **kwargs):
         raise MsgException("Method 'aioread' not implemented", http_code=HTTPStatus.INTERNAL_SERVER_ERROR)