- :param loop: asyncio loop
- :callback: callback function that will handle the message in kafka bus
- :*args: optional arguments for callback function
- :return: topic, key, message
+ :param loop: asyncio loop. To be DEPRECATED! in near future!!! loop must be provided inside config at connect
+ :param callback: synchronous callback function that will handle the message in kafka bus
+ :param aiocallback: async callback function that will handle the message in kafka bus
+ :param group_id: kafka group_id to use. Can be False (set group_id to None), None (use general group_id provided
+ at connect inside config), or a group_id string
+ :param kwargs: optional keyword arguments for callback function
+ :return: If no callback defined, it returns (topic, key, message)