Fix bug related with UnknownMemberIdError and AioKafkaConsumer #336
Description
Log:
stock-wallet-kafka-1 | [2022-03-27 14:44:08,392] INFO [GroupCoordinator 1001]: Member aiokafka-0.7.2-04adae7b-7d86-49d1-a55c-f09cf833ca4d in group crypto has failed, removing it from the group (kafka.coordinator.group.GroupCoordinator)
stock-wallet-kafka-1 | [2022-03-27 14:44:08,392] INFO [GroupCoordinator 1001]: Preparing to rebalance group crypto in state PreparingRebalance with old generation 9 (__consumer_offsets-3) (reason: removing member aiokafka-0.7.2-04adae7b-7d86-49d1-a55c-f09cf833ca4d on heartbeat expiration) (kafka.coordinator.group.GroupCoordinator)
stock-wallet-kafka-1 | [2022-03-27 14:44:08,392] INFO [GroupCoordinator 1001]: Group crypto with generation 10 is now empty (__consumer_offsets-3) (kafka.coordinator.group.GroupCoordinator)
stock-wallet-microservice-crypto-1 | 2022-03-27 14:44:09 [T:MainThread] INFO:src.commands.services: crawling kraken
stock-wallet-microservice-crypto-1 | 2022-03-27 14:44:12 [T:MainThread] INFO:src.commands.services: 672 candles in total from 2022-02-27T15:00:00.000Z to 2022-03-27T14:00:00.000Z
stock-wallet-microservice-crypto-1 | 2022-03-27 14:44:12 [T:MainThread] INFO:minos.aggregate.snapshots.services: Performing periodic Snapshot synchronization...
stock-wallet-microservice-crypto-1 | 2022-03-27 14:44:12 [T:MainThread] ERROR:aiokafka.consumer.group_coordinator: OffsetCommit failed for group crypto due to group error ([Error 25] UnknownMemberIdError: crypto), will rejoin
stock-wallet-microservice-crypto-1 | 2022-03-27 14:44:12 [T:MainThread] ERROR:aiokafka.consumer.group_coordinator: OffsetCommit failed for group crypto due to group error ([Error 25] UnknownMemberIdError: crypto), will rejoin
stock-wallet-microservice-crypto-1 | 2022-03-27 14:44:12 [T:MainThread] ERROR:aiokafka.consumer.group_coordinator: OffsetCommit failed for group crypto due to group error ([Error 25] UnknownMemberIdError: crypto), will rejoin
stock-wallet-microservice-crypto-1 | 2022-03-27 14:44:12 [T:MainThread] ERROR:aiokafka.consumer.group_coordinator: OffsetCommit failed for group crypto due to group error ([Error 25] UnknownMemberIdError: crypto), will rejoin
stock-wallet-microservice-crypto-1 | 2022-03-27 14:44:12 [T:MainThread] ERROR:aiokafka.consumer.group_coordinator: OffsetCommit failed for group crypto due to group error ([Error 25] UnknownMemberIdError: crypto), will rejoin
stock-wallet-microservice-crypto-1 | 2022-03-27 14:44:12 [T:MainThread] ERROR:aiokafka.consumer.group_coordinator: OffsetCommit failed for group crypto due to group error ([Error 25] UnknownMemberIdError: crypto), will rejoin
stock-wallet-microservice-crypto-1 | 2022-03-27 14:44:12 [T:MainThread] ERROR:aiokafka.consumer.group_coordinator: OffsetCommit failed for group crypto due to group error ([Error 25] UnknownMemberIdError: crypto), will rejoin
stock-wallet-microservice-crypto-1 | 2022-03-27 14:44:12 [T:MainThread] ERROR:aiokafka.consumer.group_coordinator: OffsetCommit failed for group crypto due to group error ([Error 25] UnknownMemberIdError: crypto), will rejoin
stock-wallet-microservice-crypto-1 | 2022-03-27 14:44:12 [T:MainThread] ERROR:aiokafka.consumer.group_coordinator: OffsetCommit failed for group crypto due to group error ([Error 25] UnknownMemberIdError: crypto), will rejoin
stock-wallet-microservice-crypto-1 | 2022-03-27 14:44:12 [T:MainThread] ERROR:aiokafka.consumer.group_coordinator: OffsetCommit
failed for group crypto due to group error ([Error 25] UnknownMemberIdError: crypto), will rejoin
stock-wallet-microservice-crypto-1 | 2022-03-27 14:44:12 [T:MainThread] ERROR:aiokafka.consumer.group_coordinator: OffsetCommit failed for group crypto due to group error ([Error 25] UnknownMemberIdError: crypto), will rejoin
stock-wallet-microservice-crypto-1 | 2022-03-27 14:44:12 [T:MainThread] ERROR:aiokafka.consumer.group_coordinator: OffsetCommit failed for group crypto due to group error ([Error 25] UnknownMemberIdError: crypto), will rejoin
stock-wallet-microservice-crypto-1 | 2022-03-27 14:44:12 [T:MainThread] ERROR:aiokafka.consumer.group_coordinator: OffsetCommit failed for group crypto due to group error ([Error 25] UnknownMemberIdError: crypto), will rejoin
stock-wallet-microservice-crypto-1 | 2022-03-27 14:44:12 [T:MainThread] ERROR:aiokafka.consumer.group_coordinator: OffsetCommit failed for group crypto due to group error ([Error 25] UnknownMemberIdError: crypto), will rejoin
stock-wallet-microservice-crypto-1 | 2022-03-27 14:44:12 [T:MainThread] ERROR:aiokafka.consumer.group_coordinator: OffsetCommit failed for group crypto due to group error ([Error 25] UnknownMemberIdError: crypto), will rejoin
stock-wallet-microservice-crypto-1 | 2022-03-27 14:44:12 [T:MainThread] ERROR:aiokafka.consumer.group_coordinator: OffsetCommit failed for group crypto due to group error ([Error 25] UnknownMemberIdError: crypto), will rejoin
stock-wallet-microservice-crypto-1 | 2022-03-27 14:44:12 [T:MainThread] ERROR:aiokafka.consumer.group_coordinator: OffsetCommit failed for group crypto due to group error ([Error 25] UnknownMemberIdError: crypto), will rejoin
stock-wallet-microservice-crypto-1 | 2022-03-27 14:44:12 [T:MainThread] ERROR:aiokafka.consumer.group_coordinator: OffsetCommit failed for group crypto due to group error ([Error 25] UnknownMemberIdError: crypto), will rejoin
stock-wallet-microservice-crypto-1 | 2022-03-27 14:44:12 [T:MainThread] WARNING:aiokafka.consumer.group_coordinator: Auto offset commit failed: [Error 25] UnknownMemberIdError: crypto
stock-wallet-microservice-crypto-1 | 2022-03-27 14:44:12 [T:MainThread] WARNING:aiokafka.consumer.group_coordinator: Heartbeat failed: local member_id was not recognized; resetting and re-joining group
stock-wallet-microservice-crypto-1 | 2022-03-27 14:44:12 [T:MainThread] ERROR:aiokafka.consumer.group_coordinator: Heartbeat session expired - marking coordinator dead
stock-wallet-microservice-crypto-1 | 2022-03-27 14:44:12 [T:MainThread] WARNING:aiokafka.consumer.group_coordinator: Marking the coordinator dead (node 1001)for group crypto.