腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
如果
我们
没有
在
kafka
中
使用
delivery
回
调
,
那么
在
produce
之后
调用
poll
()
有
什么
意义
吗
?
python
、
apache-kafka
、
confluent-platform
我们
正在尝试优化
我们
的python应用程序,它通过confluent python
kafka
客户端生成消息到
kafka
主题,
使用
confluent控制中心,
我们
可以检查特定的消息是否传递到
kafka
主题,所以现在的问题是,
我们
应该在producing
之后
使用
poll
()函数,因为交付
回
调
现在被删除了,
如果
我们
在</em
浏览 18
提问于2020-11-10
得票数 0
1
回答
在
confluent
kafka
客户端
中
,
什么
时候会
调用
交付
回
调
错误?
python
、
apache-kafka
、
confluent-platform
、
confluent-kafka-python
Confluent
Kafka
库(
在
本例
中
为python版本)
有
一个
produce
方法,该方法接受一个交付
回
调
函数: value=value, on_
delivery
=
delivery
_callback
浏览 2
提问于2021-06-15
得票数 2
1
回答
同花顺和轮询之间的
Kafka
生产者差异
python
、
apache-kafka
、
kafka-producer-api
、
confluent-platform
我们
有
一个
Kafka
消费者,它将读取消息,并这样做的东西,并再次发布到
Kafka
主题
使用
以下脚本{} 我尚未配置任何其他配置
在
我的配置
中
,queue.buffering.max.ms是0,所以当我
调用
produce
()时,每条消息都会被发布。
如果
我错了,请纠正我。(err, msg
浏览 1
提问于2018-10-01
得票数 13
回答已采纳
1
回答
BufferError:本地:全队列
python
、
apache-kafka
import loggingimport os try: p.
produce
event.encode('utf-8'), key=k
浏览 3
提问于2020-06-16
得票数 8
回答已采纳
1
回答
融合-卡夫卡消费者工作,但不是生产者
python
、
apache-kafka
、
jaas
、
confluent-kafka-python
、
sasl-scram
使用
融合-卡夫卡,我试图与亚马逊MSK。它似乎连接到MSK,因为消费者正在工作,但生产者
没有
生产任何东西。我向
kafka
-console-producer.sh检查了消费者模块是否正常工作。
我们
有
几个后端
使用
MSK。这里是我为开发我的服务而提到的Spring (
我们
的其他服务)配置。,
浏览 4
提问于2022-08-03
得票数 0
1
回答
ALooper_pollAll
什么
时候返回ALOOPER_
POLL
_TIMEOUT?
android-ndk
、
android-looper
让
我们
假设,两个具有相应
回
调
的文件描述符被添加到活套
中
,然后
调用
ALooper_pollAll(),超时时间为1000毫秒。在那
之后
不久,一些文件描述符就可用了,活套开始对它们
调用
回
调
。假设上一个被
调用
的
回
调
是
在
ALooper_pollAll开始运行200‘s
之后
完成的。现在,
如果
没有
任何一个描述符上的数据,
那么</em
浏览 2
提问于2017-12-01
得票数 0
回答已采纳
1
回答
I/O
回
调
中
调度的setImmediate()函数可以重新计算其他I/O通知的超时
吗
?
node.js
、
event-loop
、
libuv
Node的事件循环
有
poll
阶段。其目的是阻塞地等待I/O通知,然后执行所需的
回
调
。
在
进入此阶段之前,计算等待的超时时间。
如果
有通过setImmediate计划的操作,则超时设置为0,
如果
计时器发生了,而超时时间被设置为视图,
如果
没有
这样的障碍,阻塞将“永远”继续。
如果
超时最初设置为“无穷大”,并且I/O
回
调
使用
setImmediate或setInterval调
浏览 1
提问于2021-01-24
得票数 0
回答已采纳
2
回答
由于Docker延迟而导致
Kafka
超时
python
、
docker
、
jenkins
、
apache-kafka
我们
对
Kafka
(Apache)队列的持续集成测试
在
本地机器上运行得很好,但是
在
Jenkins CI服务器上,偶尔会出现这样的错误: except: print("Bang!")但是,不会引发任何异常,并且
调用
返回一个其他有效的生产者,因此我无法以编程方式测试代理端点的存在。
浏览 3
提问于2017-10-17
得票数 1
1
回答
kafka
消费者/生产者如何提交消息/分区?
apache-kafka
我刚刚开始与卡夫卡合作,并开始
在
我的本地机器上玩卡夫卡。我能够
使用
confluent提供的生成和
使用
消息。
kafka
客户端(即消费者和生产者)维护一个消息队列。生产者将把每条产生的消息存储
在
本地缓冲队列
中
。生产者需要显式地将消息从本地缓冲区推送到
kafka
集群。
在
消费者端,它将以某种方式从
kafka
集群
中
获取消息,并将其存储
在
本地缓冲区队列
中
,然后通过a
浏览 0
提问于2020-05-08
得票数 0
回答已采纳
1
回答
boost:asio async_receive_from同步运行
c++
、
boost
、
boost-asio
在下面的代码
中
,asynch_receive_from同步运行。
在
收到数据之前,它不会返回。看一下末尾的日志就会发现这一点。这一点一开始可能不是
那么
明显,因为
有
相当高的数据传入速率。但当
没有
数据时,只有一秒的心跳消息,这些异步
调用
的返回也
在
一秒左右。 问题是,为
什么
这些异步
调用
没有
立即返回(
在
几个微秒内),并且
没有
读取字节?我认为在运行队列中有其他项可能会简化这个过程,认为
浏览 1
提问于2011-06-30
得票数 0
回答已采纳
1
回答
查看是否
在
模型
回
调
中
ruby-on-rails
、
rails-activerecord
有时,我想要一个可以独立
使用
和在Rails
回
调
中
使用
的方法,让它的行为略有不同。我希望我的方法
中
的save()
调用
在
回
调
中被忽略。
那么
,
在
Rails中有
没有
一个方法来判断我当前是否处于ActiveModel
回
调
的上下文中。最后的办法是
使用
回溯,但我希望
有
一个更好的解决方案。我的模型
有
某种状态机。
浏览 2
提问于2016-01-13
得票数 0
2
回答
node.js
中
的异步
调用
node.js
、
express
对于
使用
快件和中间件的异步
调用
,我
有
一个基本的误解,我非常希望能帮助理解它。“hello”时: 有谁能给我解释一下这个流程
吗</em
浏览 0
提问于2018-06-26
得票数 0
2
回答
如何才能让`.then()‘存活足够长的时间以满足带有本机承诺的轮询函数?
javascript
、
callback
、
promise
摘要:带有
回
调
的
poll
()函数是可用的;我还
没有
找到任何
使用
本机承诺的函数。我试过调整一些,但
没有
成功。我认为这是运行的方式(
如果
我错了,请纠正我):
在
调用
poll
() *1
之后
,
我们
很快
在
*2返回一个悬而未决的承诺,以便
poll
()知道等待。
如果
fn() (
在
p()之外称为waitIsOver())
浏览 1
提问于2016-08-05
得票数 5
回答已采纳
1
回答
为
什么
我们
不能叫Twisted延迟两次?
python
、
twisted
来自以下指南: 有人能给我一个
浏览 2
提问于2014-05-13
得票数 7
回答已采纳
1
回答
Linux网络驱动程序
中
的并发性:探测() VS ndo_open(),ndo_start_xmit()与NAPI轮询()
networking
、
concurrency
、
linux-kernel
、
linux-device-driver
1. .probe诉.ndo_open
在
PCI网卡的驱动程序
中
,net_device实例通常在.probe()
回
调
中注册。内核是否
有
可能在.ndo_open
回
调
结束之前但在register_netdev()
之后
调用
该.probe
回
调
?我想是的,但可能是,
有
一个更有力的保证,可以确保设备不能在.probe结束之前打开?换句话说,
如果
.probe
回
浏览 0
提问于2013-07-27
得票数 5
回答已采纳
1
回答
epoll_insert的详细功能
linux
、
io
、
linux-kernel
、
linux-device-driver
、
epoll
epoll_insert函数由sys_epoll_ctl
调用
。
在
epoll_insert函数中有一些关键步骤:
如果
文件已经“准备好”,
那么
我们
将它放到准备列表
中
如果
文件已经“准备好”,
我们
将其放到准备列表*/ if ((
浏览 0
提问于2016-08-06
得票数 0
回答已采纳
1
回答
当
使用
librdkafka时,当
使用
事务时,预期的传递回
调
行为是
什么
?
apache-kafka
、
librdkafka
当消息成功地生成时,或者
如果
librdkafka遇到永久故障,或者临时错误的重试计数器已经耗尽,就会
调用
回
调
。应用程序必须定期
调用
RdKafka::
poll
(),以便为排队的传递报告
回
调
服务。卡夫卡交易的文件规定:
Kafka
使用
者只有
在
事务实际提交时才会向应用程序传递事务性消息。换句话说,
使用
者不会传递作为开放事务的一部分的事务性消息,也不会传递作为中止事务的一部分的消息。我认为,
如果</
浏览 4
提问于2022-06-20
得票数 0
回答已采纳
3
回答
递延对象和它自己的承诺对象之间
有
什么
区别?
javascript
、
jquery
、
deferred
“挂起”状态3秒,然后切换到“已解决”状态(此时将
调用
绑定到它的所有
回
调
)。让
我们
还检索延迟对象的承诺:现在,要添加将在解析延迟对象
之后
调用
的
回
调
,
我们
可以
使用
.done()或.then()。defer.then( handler );promise.then( handler ); 在这两种情况下,都将
调用
handler函数(
在
浏览 2
提问于2011-11-10
得票数 27
回答已采纳
6
回答
kafka
-python
使用
者未收到消息
python
、
apache-kafka
、
kafka-consumer-api
、
kafka-python
我
在
使用
KafaConsumer时遇到了麻烦,无法让它从头开始读取,或者从任何其他显式偏移量读取。/
kafka
-console-consumer.sh --zookeeper {localhost:port} --topic {topic_name} --from-beginning我
使用
的是
kafka
-python 0.9.5,而代理运行的是<
浏览 1
提问于2016-02-05
得票数 12
1
回答
在
Spring
中
,哪种方法做同样的事情,比如onPartitionsRevoked?
apache-kafka
、
spring-kafka
我知道
在
斯平-卡夫卡,
我们
有
以下方法:void onPartitionsAssigned(地图分配,ConsumerSeekCallback
回
调
);但是,它所执行的任务与本机ConsumerRebalanceListener方法o
浏览 9
提问于2017-04-02
得票数 1
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Kafka-Clients源码学习:KafkaProducer篇
图解|深入揭秘 epoll 是如何实现 IO 多路复用的!
Kafka消费者主流程概况
linux开发各种I/O操作简析,以及select、poll、epoll机制的对比
深入浅出Rust异步编程之Tokio
热门
标签
更多标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
活动推荐
运营活动
广告
关闭
领券