OrcHome
kafka教程
kubernetes教程
bootstrap5
java
资讯
问答
分享
创建
分享
写文章
问答
提问
kafka提问
kubernetes提问
全部标签
Linux
KubeBiz
kubeadm
docker
Prometheus
istio
nginx
区块链
AngularJS
minikube
ethereumj
ElasticSearch
redis
jetty
Helm
logstash
zookeeper
ceph
etcd
gradle
shell
angular
webpack
RabbitMq
netty
dubbo
sbt教程
python
kubeflow
Yammer Metrics
Tekton
kaniko
KubeVirt
Cephadm
OpenStack
kafka消费端配置为手动提交,当发生重平衡之后重新poll()消息时从什么位置开始poll()?
123
发表于: 2021-06-08 最后更新时间: 2021-06-08 22:31:43
892
游览
kafka
104
问答区
1374
最新动态
54
实用工具
6
视频
1
如图:
kafka
分享
编辑此页
历史版本
发表于 2021-06-08
123
添加评论
评论
有 3 条评论
从2开始,每次都是最后一次提交的位置。
123
->
半兽人
3年前
你是指重平衡后原consumer从2开始拉消息吗?
半兽人
->
123
3年前
是的
你的答案
评论
提交
查看
kafka
相关的其他问题或提一个
您自己的问题
。
提问
找不到想要的答案?提一个您自己的问题。
相关
828
使用的是storm框架,单例的kafka生产者是否会影响写入性能?
979
使用debezium+kafka获取mysql binlog信息,同一ip下的binlog正常获取,其他ip下的binlog信息只有创建connect时进行快照的数据,后续新增的binlog信息无法获取,请教这是什么问题?
相关
828
使用的是storm框架,单例的kafka生产者是否会影响写入性能?
979
使用debezium+kafka获取mysql binlog信息,同一ip下的binlog正常获取,其他ip下的binlog信息只有创建connect时进行快照的数据,后续新增的binlog信息无法获取,请教这是什么问题?
昵称
0
声望
这家伙太懒,什么都没留下
登录
账户
密码
取消
登录
目前只支持QQ方式登录。
其他登录方式:
从2开始,每次都是最后一次提交的位置。
你是指重平衡后原consumer从2开始拉消息吗?
是的
你的答案