豆瓣网站是怎么建设的,广东网站建设发信息,南沙网站制作,临沂网站建设和轶件安装文章目录 1.重设kafka消费者位移2.示例2.1 通过 offset 位置2.2 通过时间2.3 设置到最早 1.重设kafka消费者位移
维度策略含义位移Earliest把位移调整到当前最早位移处位移Latest把位移调整到当前最新位移处位移Current把位移调整到当前最新提交位移处位移Specified-Offset把位… 文章目录 1.重设kafka消费者位移2.示例2.1 通过 offset 位置2.2 通过时间2.3 设置到最早 1.重设kafka消费者位移
维度策略含义位移Earliest把位移调整到当前最早位移处位移Latest把位移调整到当前最新位移处位移Current把位移调整到当前最新提交位移处位移Specified-Offset把位移调整成指定位移位移Shift-By-N把位移调整到当前位移 N 处N可以是负值时间DateTime把位移调整到大于给定时间的最小位移处时间Duration把位移调整到距离当前时间指定时间间隔位移处
Earliest 策略直接指定 --to-earliest。
bin/kafka-consumer-groups.sh --bootstrap-server kafka-host:port --group test-group --reset-offsets --all-topics --to-earliest –executeLatest 策略直接指定 --to-latest。
bin/kafka-consumer-groups.sh --bootstrap-server kafka-host:port --group test-group --reset-offsets --all-topics --to-latest --executeCurrent 策略直接指定 --to-current。
bin/kafka-consumer-groups.sh --bootstrap-server kafka-host:port --group test-group --reset-offsets --all-topics --to-current --executeSpecified-Offset 策略直接指定 --to-offset。
bin/kafka-consumer-groups.sh --bootstrap-server kafka-host:port --group test-group --reset-offsets --all-topics --to-offset offset --executeShift-By-N 策略直接指定 --shift-by N。
bin/kafka-consumer-groups.sh --bootstrap-server kafka-host:port --group test-group --reset-offsets --shift-by offset_N --executeDateTime 策略直接指定 --to-datetime。
bin/kafka-consumer-groups.sh --bootstrap-server kafka-host:port --group test-group --reset-offsets --to-datetime 2019-06-20T20:00:00.000 --executeDuration 策略我们直接指定 --by-duration。
30分钟前
bin/kafka-consumer-groups.sh --bootstrap-server kafka-host:port --group test-group --reset-offsets --by-duration PT0H30M0S --execute2.示例
2.1 通过 offset 位置
不同的版本下面的路径可能不一样
cd /opt/kafka_2.11-2.0.0/bin
unset JMX_PORT
kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9192 --group galaxy_device --reset-offsets --topic GALAXY_AUTH_EVENTS_ORG --shift-by offst数字 --execute找到现在消费者 offset 位置可以通过 kafka tools 工具修改上面脚本中 offst数字 91即跳过一条记录
galaxy_device 消费组名称GALAXY_AUTH_EVENTS_ORG 主题名称
2.2 通过时间
cd /opt/kafka_2.11-2.0.0/bin
unset JMX_PORT
kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:16712 --group galaxy_device --reset-offsets --topic GALAXY_AUTH_EVENTS_ORG --to-datetime 2023-03-26T00:00:00.000 --executegalaxy_device 消费组名称GALAXY_AUTH_EVENTS_ORG 主题名称
2.3 设置到最早
kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:16712 --group profile-push-core-1 --reset-offsets --topic MessageProfile --to-earliest --executeprofile-push-core-1 消费组名称MessageProfile 主题名称
如图
