OrcHome OrcHome
OrcHome个人中心.

千鹤·重弹

已关注 关注

关注

暂无关注.....

粉丝

暂无粉丝.....


发表了 JAVA8有没有能力调用scala带闭包参数的方法? 修改
1月前
千鹤·重弹 Scala与JAVA互操作 发表评论:
我就想知道在java里怎么遍历scala的Collection类   费了牛劲都搞不定。。
2月前
半兽人 回复 千鹤·重弹 kafka enable.auto.commit=false,模拟fetch回数据消费侧业务处理失败的场景(这样不会触发手动提交),发现下次fetchRequest里带的offset已经是消费成功offset了,怎么破? 中:
没办法的, kafka只有 按下标顺序读取的。
2月前
千鹤·重弹 回复 半兽人 kafka enable.auto.commit=false,模拟fetch回数据消费侧业务处理失败的场景(这样不会触发手动提交),发现下次fetchRequest里带的offset已经是消费成功offset了,怎么破? 中:
假如我不想跳过呢?本地的SubscriptionState里维持的offset有办法rollback么?
2月前
千鹤·重弹 关注了 半兽人
2月前
发表了 kafka enable.auto.commit=false,模拟fetch回数据消费侧业务处理失败的场景(这样不会触发手动提交),发现下次fetchRequest里带的offset已经是消费成功offset了,怎么破?
2月前
半兽人 回复 千鹤·重弹 请问trace日志打印“Skipping fetch for partition {} because there is an in-flight request to {}”,通常会是什么问题? 中:
那建议你用官方的消费者测试一下,什么都不要改动,看看是否有同样的现象。
还是因为逻辑导致的。另外版本也要对应。
3月前
千鹤·重弹 回复 半兽人 请问trace日志打印“Skipping fetch for partition {} because there is an in-flight request to {}”,通常会是什么问题? 中:
研究了下Fetcher的createFetchRequests方法(0.10),应该是else if (this.client.pendingRequestCount(node) == 0) 这个分支没有进去。。Apache kafka源码剖析里也没有找到想要的答案,愁死了。。
3月前
千鹤·重弹 回复 半兽人 请问trace日志打印“Skipping fetch for partition {} because there is an in-flight request to {}”,通常会是什么问题? 中:
这个查过了   对应发不出fetch请求的consumer lag值一直飙升  我们现在就是做了动态监控  当lag值大于某个阈值后热重启消费者。。但是这样太土了。。还是想找到根因
3月前
半兽人 回复 千鹤·重弹 请问trace日志打印“Skipping fetch for partition {} because there is an in-flight request to {}”,通常会是什么问题? 中:
## 显示某个消费组的消费详情(支持0.9版本+)
bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --describe --group test-consumer-group

看看消费者占用情况。
3月前
千鹤·重弹 回复 半兽人 请问trace日志打印“Skipping fetch for partition {} because there is an in-flight request to {}”,通常会是什么问题? 中:
这个我肯定知道啊  可是现在现象应该不是这个场景吧。。
3月前
半兽人 回复 千鹤·重弹 请问trace日志打印“Skipping fetch for partition {} because there is an in-flight request to {}”,通常会是什么问题? 中:
主题的分区数 = 消费者组内的成员数,如果成员大于分区数,则多余的成员永远拿不到消息,除非有其他的成员关闭。
3月前
千鹤·重弹 回复 半兽人 请问trace日志打印“Skipping fetch for partition {} because there is an in-flight request to {}”,通常会是什么问题? 中:
同一个主题有多个消费者组内消费   同一个节点上也有多个消费者消费不同主题  会是什么原因呢?
3月前
发表了 请问trace日志打印“Skipping fetch for partition {} because there is an in-flight request to {}”,通常会是什么问题?
3月前
千鹤·重弹 回复 undefined kafka安装和启动 中:
通信超过默认的时长,被T除lsr
4月前
千鹤·重弹 收藏了 kafka 主题!
5月前

千鹤·重弹 Scala与JAVA互操作 发表评论:
我就想知道在java里怎么遍历scala的Collection类   费了牛劲都搞不定。。
2月前
半兽人 回复 千鹤·重弹 kafka enable.auto.commit=false,模拟fetch回数据消费侧业务处理失败的场景(这样不会触发手动提交),发现下次fetchRequest里带的offset已经是消费成功offset了,怎么破? 评论:
没办法的, kafka只有 按下标顺序读取的。
2月前
千鹤·重弹 回复 半兽人 kafka enable.auto.commit=false,模拟fetch回数据消费侧业务处理失败的场景(这样不会触发手动提交),发现下次fetchRequest里带的offset已经是消费成功offset了,怎么破? 评论:
假如我不想跳过呢?本地的SubscriptionState里维持的offset有办法rollback么?
2月前
半兽人 回复 千鹤·重弹 请问trace日志打印“Skipping fetch for partition {} because there is an in-flight request to {}”,通常会是什么问题? 评论:
那建议你用官方的消费者测试一下,什么都不要改动,看看是否有同样的现象。
还是因为逻辑导致的。另外版本也要对应。
3月前
千鹤·重弹 回复 半兽人 请问trace日志打印“Skipping fetch for partition {} because there is an in-flight request to {}”,通常会是什么问题? 评论:
研究了下Fetcher的createFetchRequests方法(0.10),应该是else if (this.client.pendingRequestCount(node) == 0) 这个分支没有进去。。Apache kafka源码剖析里也没有找到想要的答案,愁死了。。
3月前
千鹤·重弹 回复 半兽人 请问trace日志打印“Skipping fetch for partition {} because there is an in-flight request to {}”,通常会是什么问题? 评论:
这个查过了   对应发不出fetch请求的consumer lag值一直飙升  我们现在就是做了动态监控  当lag值大于某个阈值后热重启消费者。。但是这样太土了。。还是想找到根因
3月前
半兽人 回复 千鹤·重弹 请问trace日志打印“Skipping fetch for partition {} because there is an in-flight request to {}”,通常会是什么问题? 评论:
## 显示某个消费组的消费详情(支持0.9版本+)
bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --describe --group test-consumer-group

看看消费者占用情况。
3月前
千鹤·重弹 回复 半兽人 请问trace日志打印“Skipping fetch for partition {} because there is an in-flight request to {}”,通常会是什么问题? 评论:
这个我肯定知道啊  可是现在现象应该不是这个场景吧。。
3月前
半兽人 回复 千鹤·重弹 请问trace日志打印“Skipping fetch for partition {} because there is an in-flight request to {}”,通常会是什么问题? 评论:
主题的分区数 = 消费者组内的成员数,如果成员大于分区数,则多余的成员永远拿不到消息,除非有其他的成员关闭。
3月前
千鹤·重弹 回复 半兽人 请问trace日志打印“Skipping fetch for partition {} because there is an in-flight request to {}”,通常会是什么问题? 评论:
同一个主题有多个消费者组内消费   同一个节点上也有多个消费者消费不同主题  会是什么原因呢?
3月前
千鹤·重弹 回复 undefined kafka安装和启动 评论:
通信超过默认的时长,被T除lsr
4月前


千鹤·重弹 收藏了 kafka 主题!
5月前

千鹤·重弹 关注了 半兽人
2月前