如何获取kafka某一topic中最新的offset
答案:2 悬赏:30 手机版
解决时间 2021-02-07 07:19
- 提问者网友：感性作祟
- 2021-02-06 11:11
如何获取kafka某一topic中最新的offset
最佳答案
- 五星知识达人网友：低血压的长颈鹿
- 2021-02-06 12:02
如果你在0.9版本以上，可以用最新的Consumer client 客户端，有consumer.seekToEnd() / consumer.position() 可以用于得到当前最新的offset：
${log.dirs}/replication-offset-checkpoint
${log.dirs}/replication-offset-checkpoint
全部回答
- 1楼网友：不想翻身的咸鱼
- 2021-02-06 12:45
若没有分区，一个topic对应的消息集在分布式集群服务组中，就会分布不均匀，即可能导致某台服务器a记录当前topic的消息集很多，若此topic的消息压力很大的情况下，服务器a就可能导致压力很大，吞吐也容易导致瓶颈。
我要举报
如以上回答内容为低俗、色情、不良、暴力、侵权、涉及违法等信息，可以点下面链接进行举报！
点此我要举报以上问答信息
大家都在看
推荐资讯