腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
kafka-python
中
的
Json
生成器
hadoop
、
apache-kafka
、
kafka-python
我正在尝试一个简单的卡夫卡生产者第一次,这将采取数据从
json
文件记录
的
记录。但是我得到了错误。我
的
Json
文件(test.
json
): { [ "name": "Alabama", { &
浏览 25
提问于2021-03-09
得票数 0
2
回答
无法向Kafka Python
中
的
Topic发送消息
python
、
apache-kafka
、
kafka-python
kafka-python
==2.0.1下面是我
的
代码,import loggingproducer.send('Jim_Topic', key=b'message-two', value=b'This is
Kafka-Python
浏览 3
提问于2020-06-16
得票数 0
1
回答
消费者Kafka通过使用python
的
Rest代理
python
、
docker
、
rest
、
apache-kafka
、
kafka-consumer-api
但是我不能用我
的
python脚本执行REST查询...有什么改正
的
建议吗?/usr/bin/pythonimport requestsimport
json
REST_PROXY_URLREST_PROXY_URL}/consumers/{CONSUMER_INSTACE}/instances/{CONSUM
浏览 100
提问于2021-05-18
得票数 0
回答已采纳
1
回答
没有来自Kafka Consumer Python
的
数据-消费者一直在监听,但什么也没有出来
python
、
docker
、
apache-kafka
、
kafka-consumer-api
、
producer-consumer
我正在寻找一种方法来显示我
的
API (本地主机)到我
的
docker使用kafka。import requestsimport time res = requests.get(res.text).encode('utf-8'))#producer.flush()
浏览 8
提问于2021-04-03
得票数 0
2
回答
Kafka produce.send从不发送消息
python
、
apache-kafka
、
kafka-python
我使用Kafka 2.12和
kafka-python
模块作为Kafka客户端。我正在尝试测试一个简单
的
生成器
:daemon = True producer = KafkaProducer(bootstrap_serversproducer.send('topic',
json
.dumps(message).encode('utf-8'))在以前
浏览 15
提问于2017-07-14
得票数 3
2
回答
如何使用Python将Django与Kafka集成?
python
、
django
、
apache-kafka
所有字段都是来自用户
的
输入。我想启动我的卡夫卡进程,一旦用户进入提交按钮在我
的
Django前端界面。所有字段都保存在Mysql
中
。a,b,c,d -访问令牌 h1,h2,h3 -搜索查询(关键字)
浏览 2
提问于2018-04-02
得票数 13
2
回答
在self.async周围获取SyntaxError,同时在mac上
的
Python3.8.5上导入KafkaProducer
python
、
python-3.x
、
apache-kafka
、
kafka-producer-api
当我运行我
的
python脚本时,我得到一个关于from kafka import KafkaProducer
的
错误。我
的
错误看起来像这样: Traceback (most recent call last): from kafka
浏览 37
提问于2020-09-07
得票数 3
3
回答
导入错误没有名为kafka
的
模块
python
、
python-2.7
、
kafka-consumer-api
上面写着: import sys consumer = KafkaConsumer('test', bootstrap_servers因为以前
的
情况很好。在安装了最新版本
的
kafka之后,它会抛出这个错误。
浏览 3
提问于2018-04-26
得票数 3
2
回答
卡夫卡消费者
的
AssertionError
python
、
cassandra
、
apache-kafka
当我尝试运行rsvp_consumer.py时,我在Mac上
的
终端
中
得到了下面的错误。
浏览 4
提问于2016-02-28
得票数 2
4
回答
只读kafka主题中
的
特定消息
apache-kafka
、
kafka-consumer-api
、
kafka-python
场景: 我正在将数据
JSON
对象数据写入kafka主题,而读取时我只想读取基于消息
中
存在
的
值
的
特定消息集。我使用
的
是
kafka-python
库。completed", value: 1, active: yes} {flow_status:"failure",value 2, active:yes} 在这里,我只想读取flow_Status为已完成
的
消息
浏览 78
提问于2019-02-18
得票数 2
回答已采纳
2
回答
为什么在python应用程序(Kafka)中出现间歇性
的
"NoBrokersAvailable“错误?
python
、
apache-kafka
、
kafka-producer-api
、
kafka-python
、
broker
通信是通过TLS完成
的
。使用
Kafka-python
==2.0.2,KafkaProducer配置如下: ssl_check_hostname=False, value_serializer=lambda x:
json
.dumps以下是我
的
问题: 当发现连接失败时,默
浏览 19
提问于2022-04-04
得票数 0
回答已采纳
1
回答
将bokeh绘图与kafka流结合使用
java
、
python
、
apache-kafka
、
bokeh
、
apache-kafka-streams
这是我目前遇到
的
一个问题。 最近,我一直在探索用于绘图
的
bokeh和用于流媒体
的
kafka。我想用这两个都做一个样例实时仪表盘。我能看到
的
唯一方法是它们都可以与scala一起使用。但目前我还不想进入scala。
浏览 0
提问于2017-11-02
得票数 0
2
回答
kafka-python
引发UnrecognizedBrokerVersion错误
python
、
apache-kafka
、
kafka-python
、
aws-msk
在使用
kafka-python
包构造KafkaProducer时,我得到了这个错误:producer = KafkaProducer(bootstrap_servers=os.environ.get('KAFKA_HOST', 'localhost:9092')) 我使用
的
是
浏览 402
提问于2019-10-31
得票数 8
回答已采纳
3
回答
python脚本在docker
中
运行时未能导入kafka库。
python
、
docker
、
apache-kafka
这个脚本运行得很完美,但是当我试图在一个码头容器
中
运行它时,它无法导入kafka库。它写着"SyntaxError:无效语法“。
json
from kafka import KafkaProducerfrom kafka import SimpleProducer url = 'https://stream.twitter.com/1.1/s
浏览 6
提问于2018-10-13
得票数 4
回答已采纳
1
回答
如何使用
kafka-python
发送自定义负载?(同一WIFI网络下
的
两台ubuntu机器)
python
、
apache-kafka
如何使用
kafka-python
发送自定义负载?“两台ubuntu机器”,而且都在同一个WIFI网络下(一个地址是172.20.10.2,另一个地址是172.20.10.7),我可以使用深流test4 python脚本通过kafka成功地传输检测到
的
包围盒信息但我想要定制
的
有效载荷..。因此,我尝试了一些
kafka-python
scrpit。对于生产者: from time import sleepfrom kafka import KafkaProduc
浏览 11
提问于2021-07-29
得票数 0
2
回答
如何在仍然能够自动提交
的
同时手动分配分区?
apache-kafka
、
kafka-consumer-api
、
kafka-python
我正在尝试手动将分区分配给消费者组
中
的
每个消费者。但是,当您在组
中
添加使用者时,Kafka (或者至少是
kafka-python
)假定您希望组协调器完成所有任务。有没有办法仍然保留使用使用者组
的
所有好处(特别是自动提交),同时能够手动管理分配分区?我能写一个自定义
的
分区分配器吗? 我使用
的
是
kafka-python
1.3.3库。
浏览 8
提问于2017-09-20
得票数 2
2
回答
如何确定卡夫卡
的
API版本?
apache-kafka
、
kafka-producer-api
、
kafka-python
我发现需要将api_version参数添加到KafkaProducer
中
: kafka_producer = KafkaProducer(bootstrap_servers=['kafka:9092']问题是:如何确定api_version
的
值?我尝试过像api_version=(20, 2, 1)这样
的
随机值,它也起作用了。
浏览 0
提问于2019-07-17
得票数 10
2
回答
从kafka导入KafkaClient ImportError:没有名为kafka
的
模块
python
、
apache-kafka
我安装了Python3.8.3和2.7.16版、pip install pykafka和pip install
kafka-python
。当我尝试在安装了模块
的
情况下运行Python程序时,我得到一个错误:frompykafka import KafkaClient ImportError: No module named pykafka 这里
的
问题可能是什么?
浏览 214
提问于2020-06-04
得票数 3
1
回答
将哪个时间值分配给kafka记录message.timestamp (
kafka-python
库)?
apache-kafka
、
kafka-python
在
kafka-python
库
的
正式文档
中
,对于已消耗
的
记录.timestamp属性分配
的
值实际上没有任何信息。
浏览 4
提问于2022-07-08
得票数 0
2
回答
使用python向Kafka生产者发送列表
list
、
apache-kafka
、
kafka-producer-api
listA [1,2,3] listB ["cat", "dog", "fish"] 生产者以字节
的
形式发送消息,所以我不确定如何正确设置消息,以便列表在需要引号发送消息时发送。
浏览 46
提问于2019-03-19
得票数 1
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
JSON中的树状结构数据简介
PL/SQL中实现的解析JSON
JMeter中返回Json数据的处理方法
Python中的序列化模块json
python中json模块与flask中的jsonify的比较运用
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券