kafka错误。UnsupportdCodecError:UnsupportdCode错误：kafka使用者时找不到快速压缩编解码器的库

Question

在消费者行中的消息中出现以下错误

法典：

消费者= KafkaConsumer(topic，group_id=groupid，bootstrap_servers=[host])，用于消费者中的消息:

错误：对于使用者中的消息：文件“\Python\Python38-32\lib\site packages\kafka\cconsumer\group.py”，第1192行，在next return self.next_v2（）文件“\Pthon\Python38-32\lib\sitepackages\kafka\consumer\group.pry”，行1200，在next_v2 return next（self._iterator）文件“\Python\Python38-32\lib\sitepackage \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\cconsumer\group.py”，第654行，在poll records=self.poll_once（剩余，max_records，update_ooffsets=update_offset）文件“\Python\Python38-32\lib\site package \kafkafka\Cconsumer\group.py”中，在_poll_once记录中，第707行，_=fetched_records self.ext_partition_records=self._parse_fetched_data（max_records，update_offsets=update_offset）文件“\Python\Python38-32\lib\site packages\kafka\cconsumer\fetcher.py”，第344行，fetched-records self._next_partition _records=self._passe_fetched_data（completion）文件“\Python\Python38-32\lib\site package \kafkafka\ consumer\etcher.py”，第816行，在_parse_fetched_data unpacked=list（self._unpack_message_set（tp，records））中，文件“\Python\Python38-32\lib\site packages\kafka\cconsumer\fetcher.py”，第467行，在_unpack-message_set中，用于批处理记录：文件“\Pthon\Python38-32\lib\sitepackages\kafka\center\legacy_records.py”，第245行，in iter self._buffer=memoryview（self._decompress（key_offset））文件“\Python\Python38-32\lib\site packages\kafka\record\legacy_record.py”，第186行，in _decompressself._asset_has_codec（compress_type）文件“*Python\Python38-32\lib\site-packages\kavka\record\legacy_record.y”，第126行，在_asset_has_codec中引发UnsupportedCodeError（kafka.errors.UnsupportedcodeError:UnsupportedCode错误：未找到快速压缩编解码器的库

Answer 1

UnsupportdCodecError:找不到快速压缩编解码器的库

要使用snappy压缩的消息，您需要安装snappy。

或者，如果您控制生产者，请不要使用 snappy。