在使用者行中的消息中获得以下错误
代码：
consumer = KafkaConsumer（topic，group_id = groupid，bootstrap_servers = [主机]）消费者中的消息：
错误：对于消费者中的消息：文件“ \ Python \ Python38-32 \ lib \ site-packages \ kafka \ consumer \ group.py”，行1192，位于next中返回self.next_v2（）在next_v2中，文件“ \ Python \ Python38-32 \ lib \ site-packages \ kafka \ consumer \ group.py”，行1200返回next（self._iterator）文件“ \ Python \ Python38-32 \ lib \ site-packages \ kafka \ consumer \ group.py”，行1115，在_message_generator_v2中record_map = self.poll（timeout_ms = timeout_ms，update_offsets = False）文件“ \ Python \ Python38-32 \ lib \ site-packages \ kafka \ consumer \ group.py”，行654，在民意调查中记录= self._poll_once（剩余，max_records，update_offsets = update_offsets）_poll_once中的文件“ \ Python \ Python38-32 \ lib \ site-packages \ kafka \ consumer \ group.py”，第707行记录_ = self._fetcher.fetched_records（max_records，update_offsets = update_offsets）文件“ \ Python \ Python38-32 \ lib \ site-packages \ kafka \ consumer \ fetcher.py”，行344，位于fetched_records中self._next_partition_records = self._parse_fetched_data（完成）_parse_fetched_data中的第816行的文件“ \ Python \ Python38-32 \ lib \ site-packages \ kafka \ consumer \ fetcher.py”解压=清单（self._unpack_message_set（tp，记录））_unpack_message_set中的文件“ \ Python \ Python38-32 \ lib \ site-packages \ kafka \ consumer \ fetcher.py”，第467行批量记录：文件“ \ Python \ Python38-32 \ lib \ site-packages \ kafka \ record \ legacy_records.py”，第245行，位于iter中self._buffer = memoryview（self._decompress（key_offset））_decompress中的文件“ \ Python \ Python38-32 \ lib \ site-packages \ kafka \ record \ legacy_records.py”，第186行self._assert_has_codec（compression_type）_assert_has_codec中的第126行的文件“ * Python \ Python38-32 \ lib \ site-packages \ kafka \ record \ legacy_records.py”引发UnsupportedCodecError（kafka.errors.UnsupportedCodecError：UnsupportedCodecError：找不到快速压缩编解码器的库