如何测量Kafkaproducer在一批2分钟内发送的send（）请求数
我在玩Kafka制作人的表演。我需要通过调整批量大小来减少Kafka生产者发送给Kafka集群的请求数量。批次处理作业2分钟
我试着打印中提到的指标https://kafka.apache.org/documentation/.但没有具体的指标来统计Kafka生产者向Kafka集群发送请求的数量。
预期成果：
我需要测量Kafka制作人执行呼叫或通话到Kafka集群发送记录的次数。如果Kafka花更多的时间在采取集群，然后我可以调谐在linger.ms和批量大小
共有1个答案
您应该能够使用文档中提到的一些生产者指标来获得该度量。
您可以使用请求总计。如果在2分钟窗口开始之前以及知道生产者向集群发送了多少请求之后获得该值。如果生产者正在批处理，则请求可以包含多条记录。
还有记录发送-总计用于实际记录计数，传出字节总数用于字节计数。
所有这些指标也以速率（平均每秒）的形式存在。
这应该足以实现你想要的。
-
问题内容： 我在这里尝试做的是获取给定URL的标头，以便确定MIME类型。我希望能够查看是否http://somedomain/foo/将返回例如HTML文档或JPEG图像。因此，我需要弄清楚如何发送HEAD请求，以便无需下载内容就可以读取MIME类型。有人知道这样做的简单方法吗？ 问题答案： 使用。 还有一个getheader(name)获取特定的标头。
-
一种写法同时支持 Curl 和 Swoole use \Yurun\Util\YurunHttp\Co\Batch; use \Yurun\Util\HttpRequest; $result = Batch::run([ (new HttpRequest)->url('https://www.imiphp.com'), (new HttpRequest)->url('https:
-
我有类似/1000+用户，并希望发送他们以响应单个get请求，在管理面板表中显示这些用户，这是任何方式，以便我可以返回对单个请求的响应，每批100个用户
-
我正在使用Nodejs连接GoogleApis v35。0.0告诉Google更新或删除Google索引中的页面。当我通过Google索引批处理请求发送请求时，我陷入了多部分/混合请求，多部分的主体。 通过遵循索引API文档，我可以向Google发送一个单独的页面更新请求。但是由于谷歌每天最多有200个请求，所以我需要更新更多的URL。所以，我尝试使用谷歌索引批量请求，它最多可以对100个单独的请
-
我在网上找到了这个脚本： 但我不明白如何与PHP一起使用它，也不明白params变量内部的内容是什么，也不明白如何使用它。我能帮个忙吗？
-
我使用Guzzle 6向第三方api（cloud Foundry）发送多部分表单请求。api采用两个参数“资源”和“应用程序”。这是我打电话的医生。简而言之，这会将二进制文件部署到应用程序服务器。下面是我在Guzzle中使用的代码。当试图发送一个空数组作为“resource”参数的内容时，我收到了一个“invalid resource type”错误。Guzzle似乎只允许使用字符串？api要求在