个人中心
文章发布
退出
作者热门文章
- android - 多次调用 OnPrimaryClipChangedListener
- android - 无法更新 RecyclerView 中的 TextView 字段
- android.database.CursorIndexOutOfBoundsException : Index 0 requested, 光标大小为 0
- android - 使用 AppCompat 时，我们是否需要明确指定其 UI 组件(Spinner、EditText)颜色
35
4
从 kafka 0.8.2.0 开始，跟踪消费者延迟和主题大小似乎变得非常困难
你如何跟踪偏移量(主题大小)和卡夫卡滞后？您是否会在生产者插入消息时在某处增加一个计数器，并在消费者确认消息时增加另一个计数器？
我正在使用 airbnb's kafka-statsd-metrics2 - 但出于某种原因，所有关于主题大小的指标总是 0，这可能是他们的错误报告，但你是怎么做到的？
我们的消费者和生产者使用 python 编写 kafka-python ，他们声明他们不支持 ConsumerCoordinator 偏移量 API，因此我整理了一个解决方案来查询 zookeeper 并将这些指标发送到 statsd 实例(看起来很尴尬)，但我仍然缺少主题大小指标。
我们正在使用 collectd 来收集系统指标，我没有使用 JMX 的经验并且在 collectd 中配置它似乎很复杂，我已经尝试了几次，所以我找到了一些不这样做的方法。
如果您有任何意见，我很想听听，即使是:“这属于 x stackexchange-site”
最佳答案
如果我对您的理解正确，您可以使用 FetchResponse 中的 HighwaterMarkOffset。通过这种方式，您将知道分区末尾的偏移量是多少，并且能够将其与您当前确认的偏移量或此 FetchResponse 中最后一条消息的偏移量进行比较。
详情 here
关于python - 使用 kafka 0.8.2.0 跟踪主题大小和消费者滞后，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/28839894/
35
4
0
我有一个简单的应用程序，它读取数据库，然后经过一些操作将结果写入另一个数据库。 第一行代码使用给用户的消息和屏幕日志更新 ui，然后全部包装在带有 using 和其他 try/catch 的 try/
我有一个名为activity的表，其中有一个memberId和一个时间戳。我想找出在给定的月份中有多少成员执行了一项 Activity (即-在 Activity 表中有记录)，但在过去12个月中，谁
我有前三列数据。第一个列表示 id 在前一天做了某件事。我试图通过添加一个新变量“new”来从 dat 转到 dat2，该变量执行三件事: 将 yest 的值复制到前一天。但日子并不总是连续的。因此，
我有一个简单的应用程序，它读取数据库，然后经过一些操作将结果写入另一个数据库。 第一行代码使用给用户的消息和屏幕日志更新 ui，然后全部包装在带有 using 和其他 try/catch 的 try/
我有 data.frame，它显示了股票的当前出价和要价以及我当时的信号。 time bid_price ask_price signal 10:10:01.000500
我无法让网站正常运行。它有许多移动背景并使用 css-invert 过滤器。 请看这里: http://epicstudios.de/blackwhite/ 我的问题是，即使是普通计算机也无法处理移动
我创建了一个矩形对象网格并将它们添加到一个 Pane 中。每个矩形都有一个连接到它的鼠标事件监听器，它由 MouseEvent.Entered 触发器触发。当用户将鼠标移到矩形上时，处理程序只是更改矩
感觉我的笔记本电脑不允许控制台应用程序以一定的速度运行，因为我也尝试过其他应用程序，并且它们也随机滞后。我的机器不老，也不应该这样做，它具有i7-4720HQ CPU @ 2.60GHz（8 CPUs
我现在正面临这个问题。当我的页面加载 (DOM) 时，我调用一个返回 1880 张图像的函数，这些图像存储在 Steam 服务器中。 这些图像在回调之后被添加到我的 DOM 中，该回调返回我的数组响应
我正在尝试创建一个每两秒执行一次函数的应用程序。为了实现这一点，我使用 Timer.scheduledTimer 函数。问题是该函数没有按照应有的那样每两秒执行一次。通常应用程序开始时的间隔是 2 秒
我得到了这个 gps 接收器方法，它将一些数据存储到数据库中。 // GPS private void addGPSListener() { globalconstant.db
我有一个 UISwitch，它可以在切换值时更改其上方 UILabel 的文本。每隔一段时间(大约 2% 的时间)文本不会改变。标签的文本被保存到文本文件中，因此我需要准确性。由于这个问题是间歇性的，
我有一个包含用户帖子的表格 View 。每个帖子都有图片、用户名和帖子本身。刷新控件的操作是使用来自 Parse 的数据重新加载表。除了拉动刷新时的极度延迟外，一切都完美无缺。不知道是因为每个单元格里
我有一个“详细信息”页面，其中显示俱乐部的信息。该页面是一个 UIViewController，由按钮和标签组成，以实现这种外观(就像分组的小表格)。当我在设备上加载此页面时，它比我的应用程序中的任何
我有 ActionSheet 的代码，它可以连接的东西有点慢？ @IBAction func showAction(_ sender: UIButton) { let actionSheetC
我的桌面应用程序滞后。我认为 java.awt.image.BufferStrategy 中有问题。 private void render() { BufferStrategy bs
你好，我有一个包含多个页面的 viewpager(使用 fragment 状态寻呼机)，以及一些 png 作为这些页面的背景。我已经遵循了在 Ui 中显示位图 (http://developer.an
我在 WPF 窗体上有一个 richtextbox 控件。它有 SpellChecking.IsEnabled 设置为 true 并且 VerticalScrollBarVisibility 设置为
在我的 android 应用程序中，我将数据存储在本地 SQLite 数据库中。在这个数据库的大小小于 8-9 MB 之前，一切都很顺利；然而，一旦数据库大小约为 9 MB，它就会继续在 logcat
我正在开发一个简单的 Android 应用程序，它只有一个 Activity ，一个 WebView。它在我的手机(Android 7.1.2 Nougat 版本)上运行良好，但我收到许多用户的投诉，
我是一名优秀的程序员,十分优秀！