SO中文参考
首页
(current)
程序语言
c
java
python
c++
go
javascript
swift
c#
操作系统
linux
ubuntu
centos
unix
数据库
oracle
mysql
mongodb
postgresql
框架
node.js
angular
react-native
avalon
django
twisted
hadoop
.net
移动开发
android
ios
搜索
Confluent Kafka:当我将 acks 设置为 0 时,我是否应该在生成消息后进行轮询?
问题描述
投票:0
回答:0
我有一个关于优化我的 kafka 生产者的问题(使用
confluent-kafka
库在 python 中工作)。我有一个主题,对于接收消息的领导者的确认并不重要。因此,我将
acks
设置为0.
我想知道以上内容:这是否真的意味着根本没有发送
acknowledgment
?这样我制作后就不需要
poll()
了?或者,如果我在生产后不轮询,我会冒填满内部队列的风险吗?
提前致谢!
python
apache-kafka
confluent-platform
kafka-producer-api
confluent-kafka-python
最新问题
如何防止 Bing 不定期地淹没我的网站?
NextJS 和 React-dnd 的 useDrag Ref 类型错误
使用 Vega-lite 构建甘特图
javac makefile 的问题
Quickgrid 在数据库上执行不需要的采石场
我无法通过 fluence-bit 将数据发送到 AWS OpenSearch
如何将 Jenkins 的工作阶段标记为已跳过,用于脚本化管道
MySQL 触发器无法更新表 - 出现错误 1442
尝试创建管道时,AzureDevOps 管道“经典编辑器”不可见
将 Jenkins (Docker) 连接到 Minikube Kubernetes 集群问题
在 flutter 中根据屏幕尺寸调整文本
在 VSTS Powershell 内联脚本任务中运行 drop SQL DB 时找不到类型 [Microsoft.SqlServer.Management.Smo.Server]
Spark Streaming 和集中式日志记录:将 executorId 添加到日志中
限制分支 X 只能从 Github 中的一个特定分支 Y 合并
无法使用 mongodb 在 akka http 中将 scala.concurrent.impl.Promise$Transformation 转换为 scala.collection.immutable.Seq 错误?
PathNotFoundException:无法打开文件,路径='/data/user/0/com.example.future_fit/app_flutter/preset_test.tx
如何更新远程服务器上运行的 Jetbrains 版本?
如何在selenium中为每个url发送随机代理,而无需一次又一次打开Chrome窗口
以“.htm”结尾我的网址是个好主意吗?
在 Symfony 7 上安装 Bootstrap,添加“package.json”和命令“npm start”后出现错误消息
© www.soinside.com 2019 - 2024. All rights reserved.