腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
使用
FastAPI
和
aiokafka
消费
Kafka
消息
python
、
apache-kafka
、
async-await
、
fastapi
我想创建一个用
FastAPI
来
消费
来自
Kafka
主题的
消息
的接口。我正在尝试用下面的代码创建一个入口点: import asyncioimport jsonfrom
fastapi
import APIRouter, HTTPException TOPIC_INGESTED_REQUEST,
KAFKA</
浏览 167
提问于2020-10-14
得票数 0
回答已采纳
1
回答
在异步
kafka
实现中只调用一次` implementation ()`?
python
、
apache-kafka
、
python-asyncio
我正在
使用
docker在本地机器上做一个简单的
kafka
产生/
消费
测试。代码,如下所示: import jsonimport asynciofrom confluent_
kafka
.schema_registry import Sch
浏览 22
提问于2021-10-26
得票数 0
1
回答
aiokafka
:考虑
kafka
消费
群组再均衡时,
消息
处理是否需要加锁
python
、
apache-kafka
、
aio
当
使用
ConsumerRebalanceListener启动
aiokafka
消费
者时,我们对从
kafka
接收到的批量
消息
(getmany())有一个处理过程。当重新平衡发生时,同时处理过程已经发生,on_partitions_revoked将再次调用处理过程,并可以处理两次
消息
,为了避免这种情况,我们在此过程开始时添加了一个锁。虽然我们在这种情况下
使用
aiokafka
,但我猜这对
Kafka
来说可能是一个一般性的问题。(self):
浏览 53
提问于2020-11-08
得票数 0
1
回答
AIOKafka
:以前工作的代码现在在send_and_wait上失败了
python
、
apache-kafka
、
python-asyncio
我
使用
AIOKafka
已经有一段时间了,直到今天我还没有遇到任何问题。下面是我得到的错误
消息
:Unexpected error in send
浏览 0
提问于2018-05-08
得票数 1
回答已采纳
1
回答
Aiokafka
库不异步
消费
消息
python
、
apache-kafka
、
async-await
、
python-asyncio
我正在尝试实现Python
aiokafka
异步库,但由于某些原因,我无法异步处理
消息
。 python 3.7.2
kafka
-python==1.4.3from
aiokafka
import AIOKafkaConsumer loop.run_until_compl
浏览 0
提问于2019-04-03
得票数 1
1
回答
异步生成
消息
时的ProducerClosed错误
python-asyncio
、
python-3.7
我正在
使用
aiokafka
异步生成
消息
。我有一个
使用
django的Api,它正在向
kafka
队列生成
消息
。一切都很顺利。现在,当我将相同的api转换为
使用
aiohttp服务器时,就会出现以下错误: response = awai
浏览 5
提问于2019-10-14
得票数 1
回答已采纳
1
回答
如何知道卡夫卡队列中消耗了多少数据,卡夫卡队列中存在哪些数据?
java
、
stream
、
streaming
、
apache-kafka
、
kafka-consumer-api
我正在"topicDemo“
Kafka
中生成数据
和
消费
数据,以启用分布式数据并并行处理这些数据。但在实时场景中,目前需要监视queue(topicDemo)中的数据数量
和
消耗的数据(、topicDemo、)。 有卡夫卡API提供这些细节吗?props.put("value.serializer", "org.apache.
kafka
.common.serialization.ByteArraySerializer");org.apache.
kafk
浏览 0
提问于2016-10-26
得票数 0
2
回答
可能
使用
Kafka
-连接器从Python-Opcua客户端获取数据到
Kafka
主题
apache-kafka
、
opc-ua
self, node, val, data)将作为python opcua client的一部分执行,每当client到达新数据时,请参见下面的脚本,是否可以将到达的数据(在这个上下文中是val)发送到
kafka
-client
浏览 1
提问于2020-02-19
得票数 0
回答已采纳
2
回答
使用
topic启用ACL的
Kafka
java生产者
和
消费
者
java
、
apache-kafka
、
kafka-consumer-api
、
kafka-producer-api
我对
kafka
ACL配置有点困惑,在
kafka
ACL配置中,我们为生产者
和
消费
者配置授权。有各种
使用
命令行生成/
消费
消息
的示例。我们是否需要任何额外的配置来
使用
JAVA api向/从安全的
kafka
主题生成/
消费
消息
。
浏览 2
提问于2016-06-15
得票数 0
1
回答
如何
使用
Apache Nifi在多个节点上运行
Kafka
消费
者处理器实例
apache-kafka
、
apache-nifi
目前我们
使用
Apache NiFi通过
Kafka
consumer
消费
消息
。
kafka
客户端的输出连接到hive处理器。 我正在研究如何在nifi集群上运行
kafka
消费
者实例。我有3个节点的nifi集群
和
一个有3个分区的
kafka
主题,我希望
kafka
消费
者能够在每个节点上运行,这样每个
消费
者可以从一个主题分区轮询
消息
。在我启动
kafka
<em
浏览 3
提问于2019-08-04
得票数 0
1
回答
如何从Apache Nifi中上次提交的偏移量读取consumer中的
Kafka
消息
?
apache-kafka
、
bigdata
、
kafka-consumer-api
、
apache-nifi
、
kylo
我已经开始我的生产者发送数据到
Kafka
,也开始我的
消费
者拉相同的data.When,我正在
使用
消费
卡夫卡处理器(
kafka
版本1.0)在Apache Nifi,我在我的脑海中有几个问题,与
Kafka
消费
者相关Q.1)当我第一次启动ConsumeKafka处理器时,如何读取开始
消息
和
当前
消息
? Q.2)还有在
Kafka
中
消费
者关机的情况下,如何在最后一条
消费
<em
浏览 20
提问于2018-07-30
得票数 2
回答已采纳
1
回答
Spring
kafka
多
消费
者结果组合
spring
、
apache-kafka
、
kafka-consumer-api
我有生产者,它产生一些
消息
(例如10)。有n个分区
和
一个包含n个
消费
者的
消费
者组。
Kafka
系统将
消息
分发到
消费
者之间。我如何将所有
消费
者的
消息
组合在一个地方,以便我有10条
消息
。我
使用
的是
Kafka
和
Spring。
浏览 10
提问于2019-02-10
得票数 0
1
回答
用ConsumerStoppedError运行浮士德卡夫卡崩溃
python-3.x
、
apache-kafka
、
faust
我刚安装了浮士德,并运行了一个基本程序来通过
Kafka
发送
和
接收
消息
。我在运行()中提到的示例代码时
使用
了这个程序,最初它连接到
Kafka
(它也运行在我的机器上)。但是,在尝试
消费
的同时,
Kafka
被断开连接,应用程序崩溃,只有下面的例外 [2020-11-11 07:08:26,623] [76392] [ERROR] [^---Fetcher]: CrashedLibrary/Frameworks/Python.framework/Ve
浏览 4
提问于2020-11-11
得票数 4
回答已采纳
1
回答
如何
使用
Kafka
Java api检查
消费
者数据
apache-kafka
、
kafka-consumer-api
、
kafka-producer-api
这是我的
消费
者代码: props.put("group.id", "testgroup"); props.put("
kafka
.topic/
kafka
-server-
浏览 0
提问于2016-04-03
得票数 0
1
回答
重构卡夫卡信息的可能原因
go
、
apache-kafka
、
kafka-consumer-api
、
sarama
昨天,我从日志中发现,卡夫卡在卡夫卡小组协调员发起了一次小组再平衡之后,正在重新
消费
一些信息。这些
消息
是两天前
使用
的(从日志中确认)。config.Version = version在声明
消息
之前,我们正在处理混乱,因此似乎我们至少
使用
了一次
kafka</em
浏览 0
提问于2019-07-02
得票数 0
回答已采纳
3
回答
Broker (
Kafka
和
RabbitMQ)
rabbitmq
、
apache-kafka
在讨论卡夫卡
和
RabbitMQ的区别时,“哑巴经纪人”
和
“智能经纪人”在与
消费
者的互动中不断出现。卡夫卡被描述为有一个愚蠢的经纪人,而RabbitMQ据说有一个聪明的经纪人/愚蠢的
消费
者模型。
浏览 5
提问于2017-08-28
得票数 11
2
回答
使
Kafka
生产者
和
消费
者同步
apache-kafka
我有一个卡夫卡制作人和consumer.The卡夫卡制作人发布到一个主题,数据被获取
和
一些处理完成。
kafka
消费
者正在从另一个主题中读取关于主题1中的数据处理是否成功或失败的信息,即主题2是否成功或失败。我正在启动我的
消费
者,然后将数据发布到主题1。.I想使生产者
和
消费
者同步,即一旦生产者发布数据,
消费
者应该读取该数据的成功或失败
消息
,然后生产者应该继续处理下一组数据。
浏览 3
提问于2017-08-01
得票数 2
3
回答
Apache
Kafka
是JMS的另一个API吗?
migration
、
apache-kafka
、
jms
Apache
Kafka
不是JMS的另一种实现吗 我正在我的应用程序中
使用
JMS+AMQ,并迁移到Apache
Kafka
。我必须更改所有的JMS代码吗?
浏览 2
提问于2015-05-26
得票数 25
回答已采纳
2
回答
JMS与特定条件下的
Kafka
jms
、
apache-kafka
Kafka
保证有序投递
和
多订阅者。卡夫卡是怎么做到的?Q1:在这种情况下,哪个更好?请给我提个建议。
浏览 1
提问于2017-03-08
得票数 18
回答已采纳
2
回答
如何从
kafka
消息
总线推送通知
消费
者
c#
、
apache-kafka
、
confluent-platform
我正在
使用
C# asp.net Core2.0,
Kafka
,CQRS
和
Confluent
Kafka
.net库编写微服务应用程序。只是想知道
kafka
是否可以通知
消费
者,而不是
消费
者投票/
消费
消息
? 谢谢
浏览 0
提问于2018-09-11
得票数 0
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
使用Apache Kafka的Golang实践指南
DK.Kafka消息引擎系统的相关知识
Kafka详细的设计和生态系统
Kafka的系统设计
Kafka系列-3-Kafka架构介绍
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券