티스토리 뷰

공부

[Kafka] reset-offsets

승가비 2020. 11. 21. 00:01
728x90
brew install kafka

kafka-consumer-groups --bootstrap-server https://asdf.com \
--topic topic_v1 \
--group consumer \
--reset-offsets --to-earliest --execute

kafka-consumer-groups --bootstrap-server https://asdf.com \
--topic topic_v1 \
--group consumer \
--reset-offsets --to-latest --execute

kafka-consumer-groups --bootstrap-server https://asdf.com \
--topic topic_v1 \
--group consumer \
--reset-offsets 1 --execute

kafka-consumer-groups --bootstrap-server https://asdf.com \
--topic topic_v1 \
--group consumer \
--reset-offsets --to-datetime 2020-11-11T00:00:00.000+0900 --execute

 

https://blog.voidmainvoid.net/304

 

카프카 장애대응 - Consumer offset 지정하기(by partition)

카프카 consumer로 입수를 진행하다보면 예상치 못하게 데이터가 중복입수 또는 유실될 가능성이 있습니다. - Kafka broker 이슈 - Network 이슈 - Consumer application 이슈 위와 같은 이슈가 발생했을 경우

blog.voidmainvoid.net

https://stackoverflow.com/questions/29791268/how-to-change-start-offset-for-topic

 

How to change start offset for topic?

It is possible to change the start offset for a new topic? I would like to create a new topic and start reading from the offset 10000. How?

stackoverflow.com

 

728x90
저작자표시 비영리

'공부' 카테고리의 다른 글

[JS] Github Pages (gatsby.js)  (0) 2020.11.21
[Spark] streaming throughput  (0) 2020.11.21
[Hive] How to copy table  (0) 2020.11.20
[Java] init HashMap()  (0) 2020.11.20
[SQL] ORDER BY RAND()  (0) 2020.11.20
댓글