腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
Python
KafkaConsumer
未
连接
docker
、
apache-kafka
、
jupyter-notebook
、
kafka-consumer-api
、
kafka-producer-api
KafkaConsumer
.ipynb KAFKA_BROKER = ['172.20.0.2:9093'] consumer =
KafkaConsumer
但是,客户端不能
连接
到同一个代理进行数据消费。我该如何开始调试呢?
浏览 11
提问于2020-01-29
得票数 2
1
回答
Kafka-
python
连接
丢失
python
、
exception-handling
、
kafka-consumer-api
、
kafka-python
我想知道如何验证与kafka的
连接
:让我更好地解释:有什么方法可以检查
连接
吗?我使用的是kafka-
python
版本1.3.3。这是一段代码:for msg in consumer: DO....
浏览 1
提问于2018-01-14
得票数 0
2
回答
为JSON创建kafka流API
apache-kafka
、
apache-kafka-streams
我正在尝试编写一个卡夫卡流代码,用于将JSON数组转换为JSON elements...since,我对kafka流还不熟悉,任何人都可以帮助我编写代码吗?就像kstream和ktable应该有什么..。而我的输入流将采用以下格式 {"timestamp":"2017-10-24T12:44:09.359126933+05:30","data":0,"unit":""}, {"timestamp":"2017-10-24T12:44:09.359175426+05:30",&
浏览 4
提问于2017-11-27
得票数 0
回答已采纳
1
回答
Python
:无法导入名称
KafkaConsumer
python
、
apache-kafka
我为
Python
安装了kafka-
python
包。我有一个卡夫卡制作人和消费者运行。我希望
python
代码能够阅读kafka主题并打印出消息。我的
python
代码如下:from kafka import
KafkaConsumer
print "Step 1 complete" consumer=
KafkaConsumer
('test',bootstrap_servers=
浏览 1
提问于2016-07-28
得票数 8
1
回答
使用
Python
3将ApacheSpark3.0
连接
到Kafka
python-3.x
、
apache-kafka
、
spark-streaming
、
stream-processing
我正在开发一个小的大数据项目,我想知道是否有一种方法可以使用
python
3从SparkStreamingv3.0中读取卡夫卡主题中的流。我在上读到了链接工件火花流-kafka-0-10_2.12来处理这类流所必需的内容,但我发现这些依赖项与
Python
不兼容(在集成指南中,只有使用Java或Scala的示例,并且来自不同版本的stream,我读到没有支持
python
语言:)。我可以切换当前的堆栈选项,因此欢迎其他建议,但我不会将
Python
更改为我的脚本语言。 提前谢谢。
浏览 2
提问于2020-07-18
得票数 1
1
回答
Python
用avro存储库反序列化kafka消息
python-3.x
、
apache-kafka
、
avro
使用kafka-
python
2.0.2,我可以
连接
到Kafka主题并阅读这些信息,但我不知道如何解码它们。from kafka import
KafkaConsumer
other合流-kafka 1.5.0,avro-
python
3 3 1.10.1如何进行?要
连接
到avro存储库,我有以下参数 basic.auth.credential
浏览 2
提问于2021-01-26
得票数 0
回答已采纳
2
回答
Python
-读取所有消息后退出Kafka队列
python
、
apache-kafka
、
kafka-consumer-api
我正在尝试使用
Python
读取Kafka队列的一些数据,如以下代码所示:import sysimport pandasas pd topicName = 'topic' df = pd.json_normalize
浏览 14
提问于2021-03-09
得票数 1
1
回答
没有来自Kafka Consumer
Python
的数据-消费者一直在监听,但什么也没有出来
python
、
docker
、
apache-kafka
、
kafka-consumer-api
、
producer-consumer
import kafkaimport requestsconsumer =
KafkaConsumer
('test', bootstrap_servers=['localhost:9092'], api_version='2.0.0', group_id="test_id",当我手动停止时,我从docker得到以下错误:<class '
浏览 8
提问于2021-04-03
得票数 0
2
回答
无法
连接
到卡夫卡在一个对接的环境中从水瓶
python
、
docker
、
flask
、
apache-kafka
、
connection
我使用了
Python
连接
器、和Docker图像作为Kafka,。/flask-app:/app - kafka TOPICS = ['PROFILE_CREATED
浏览 1
提问于2018-11-27
得票数 5
1
回答
是否有方法配置
KafkaConsumer
(apache.kafka.kafka-客户端)通过代理与Kafka代理一起工作?
java
、
apache-kafka
、
proxy
我使用
KafkaConsumer
java客户端与Kafka代理进行
连接
。我的用户可以在
KafkaConsumer
和代理之间定义一个代理(ip : port)。------ ------------- ----------------------- 如果没有代理,配置“boostrap.servers”和代理列表就足以建立初始
连接
我的问题是,如何通过代理管理
KafkaConsumer
来初始化与代理的
连接
?有这种支持吗?
浏览 3
提问于2020-03-22
得票数 1
1
回答
如何将
KafkaConsumer
与Django4结合使用
django
、
apache-kafka
、
kafka-python
我有一个Django 4项目,并且使用了kafka的
KafkaConsumer
。我想更新django模型后,收到卡夫卡的消息。
浏览 5
提问于2022-08-05
得票数 0
2
回答
Python
Kafka模仿返回类型的Kafka Consumer
python
、
unit-testing
、
apache-kafka
、
mocking
当我使用kafka-
python
包时,我想测试一个脚本。我想测试函数的返回对象类型 consumer =
KafkaConsumer
(bootstrap_serverstest_get_kafka_consumer_output_type(self): self.assertIsInstance(result,
KafkaConsumer<
浏览 20
提问于2020-07-30
得票数 1
1
回答
在
python
中为Kafka代理指定SSL详细信息
python-3.x
、
ssl
、
apache-kafka
、
kafka-python
我需要
连接
到kafka实例,它有多个代理与SSL。我正在使用kafka-
python
来消费和处理数据。特定代码 security_protocol
浏览 252
提问于2018-07-18
得票数 0
1
回答
尝试在Windows上的Kafka中实现SSL/TLS时出现java.lang.OutOfMemory错误
windows
、
ssl
、
apache-kafka
authentication with /10.2.9.200 (SSL handshake failed) (org.apache.kafka.common.network.Selector) 此外,当我尝试用
python
创建一个消费者时,我得到了: >>> from kafka import
KafkaConsumer
>>> c =
KafkaConsumer
(bootstrap_servers='vmnala:9092security_protocol = "SSL&
浏览 95
提问于2020-06-18
得票数 1
1
回答
Spring cloud stream -为给定的PollableMessageSource自动装配底层消费者
spring-kafka
、
spring-cloud-stream
是否有可能获得已定义PollableMessageSource的底层
KafkaConsumer
bean?(PollableMessageSource testTopic) {
KafkaConsumer
kafkaConsumer
= getConsumer(testTopic); while (true) {Thr
浏览 28
提问于2019-07-19
得票数 0
回答已采纳
1
回答
卡夫卡蟒蛇-找到新的卡夫卡主题,消费者还没有订阅正确的方式是什么?
python
、
apache-kafka
、
kafka-consumer-api
、
kafka-python
、
confluent-kafka-python
我是卡夫卡世界的新手,我试图在
python
中为卡夫卡的消费者做以下的事情任何帮助都将不胜感激。
浏览 1
提问于2021-04-21
得票数 0
回答已采纳
1
回答
Flask API作为实时kafka消费者
python
、
flask
、
apache-kafka
我想构建一个使用Flask框架开发的
python
API,它使用Kafka主题并将流推送到客户端(html页面或其他应用程序)。import time application = Flask(__from kafka import
Kaf
浏览 8
提问于2016-12-02
得票数 6
1
回答
卡夫卡消费者调查与重新联系
apache-kafka
、
long-polling
、
kafka-consumer-api
我有一些与
KafkaConsumer
相关的查询。 Consumer<String, String> consumer = new
KafkaConsumer
<String,String>(props); consumer.subscribe你能帮我理解一下
KafkaConsumer
民意测验的
浏览 1
提问于2016-07-26
得票数 3
回答已采纳
1
回答
卡夫卡消费者是否每个分区都有一个开放的
连接
?
apache-kafka
、
kafka-consumer-api
如果每个分区都有一个打开的
连接
,那么我可以想象每个用户打开了数万个
连接
。如果这是真的,那么在决定分区的数量时,这似乎是值得注意的事情,不是吗?
浏览 3
提问于2018-05-31
得票数 3
回答已采纳
1
回答
卡夫卡消费者什么时候有了联系?
java
、
connection
、
kafka-consumer-api
我想知道卡夫卡消费者什么时候有了联系。
浏览 1
提问于2022-02-03
得票数 0
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
python代码中用密码连接redis连接池
python前后端连接程序
Python mysql连接池
Python连接MySQL的条条大路
python连接mysql数据库
热门
标签
更多标签
活动推荐
运营活动
广告
关闭
领券