kafka-python通过Snappy压缩访问时,报Snappy codec ?报错-问答-阿里云开发者社区-阿里云

开发者社区> 爱吃鱼的程序员> 正文

kafka-python通过Snappy压缩访问时,报Snappy codec ?报错

2020-06-10 11:03:09 161 1

1、测试环境:

    CentOS6.5_64位、JDK1.7、kafka版本为:kafka_2.9.2-0.8.2.2,zookeeper版本为:zookeeper-3.4.6,

kafka-python-0.9.4 。

2、测试步骤:

    已经安装好zookeeper和kafaka环境,设置codec=CODEC_SNAPPY则报错,codec=CODEC_NONE或者是codec=CODEC_GZIP则正常,此时怀疑是未安装SNAPPY

    安装SNAPPY,进行测试,发现还是报错:

错误如下:

Traceback (most recent call last):
  File "/usr/local/kafkaTest/producer.py", line 67, in <module>
    main()
  File "/usr/local/kafkaTest/producer.py", line 63, in main
    load(hostname, max_size, loaded)
  File "/usr/local/kafkaTest/producer.py", line 22, in load
    producer.send_messages('topic1', big_msg)
  File "build/bdist.linux-x86_64/egg/kafka/producer/simple.py", line 54, in send_messages
  File "build/bdist.linux-x86_64/egg/kafka/producer/base.py", line 349, in send_messages
  File "build/bdist.linux-x86_64/egg/kafka/producer/base.py", line 385, in _send_messages
  File "build/bdist.linux-x86_64/egg/kafka/protocol.py", line 603, in create_message_set
  File "build/bdist.linux-x86_64/egg/kafka/protocol.py", line 586, in create_snappy_message
  File "build/bdist.linux-x86_64/egg/kafka/codec.py", line 76, in snappy_encode
NotImplementedError: Snappy codec is not available

测试代码如下:

producer = SimpleProducer(client,async=False,codec=CODEC_SNAPPY,req_acks=0,ack_timeout=2000,sync_fail_on_error=False)
<p>
	<br>
</p>
<p>
	<br>
</p>



取消 提交回答
全部回答(1)
相关问答

4

回答

Spark 【问答合集】

社区小助手 2019-05-29 14:13:40 123712浏览量 回答数 4

28

回答

钉钉开放平台“常见问题常见问题常见问题“重要请关注

竹梅 2015-12-03 00:39:14 92894浏览量 回答数 28

22

回答

爬虫数据管理【问答合集】

我是管理员 2018-08-10 16:37:41 146786浏览量 回答数 22

41

回答

OSS FTP工具发布啦

oss-dev 2015-12-23 16:58:56 66013浏览量 回答数 41

42

回答

【精品问答集锦】Python热门问题

小六码奴 2019-05-30 15:27:34 135561浏览量 回答数 42

249

回答

阿里云LNAMP(Linux + Nginx + Apache + MySQL + PHP)环境一键安装脚本

云代维 2014-02-14 15:26:06 302606浏览量 回答数 249

49

回答

阿里云产品选购常见FAQ

qiujin2012 2013-05-14 14:19:59 110277浏览量 回答数 49

39

回答

【云服务器分享】简述云服务器对比VPS

dreamdoo 2012-10-08 16:24:18 118170浏览量 回答数 39

24

回答

【精品问答】python技术1000问(1)

问问小秘 2019-11-15 13:25:00 471427浏览量 回答数 24

30

回答

基础语言百问-Python

薯条酱 2017-05-17 18:01:13 64756浏览量 回答数 30
+关注
爱吃鱼的程序员
https://developer.aliyun.com/profile/5yerqm5bn5yqg?spm=a2c6h.12873639.0.0.6eae304abcjaIB
2
文章
21569
问答
推荐问答
相关电子书
更多
文娱运维技术
立即下载
《SaaS模式云原生数据仓库应用场景实践》
立即下载
《看见新力量:二》电子书
立即下载