Allow the coordinator to auto-commit for api_version==0.8.1

Author: justecorruptio

kafka/coordinator/consumer.py

@@ -256,7 +256,7 @@ def poll(self):
         ensures that the consumer has joined the group. This also handles
         periodic offset commits if they are enabled.
         """
-        if self.group_id is None or self.config['api_version'] < (0, 8, 2):
+        if self.group_id is None or self.config['api_version'] < (0, 8, 1):
             return
 
         self._invoke_completed_offset_commit_callbacks()