diff --git a/docs/development/extensions-core/kafka-supervisor-operations.md b/docs/development/extensions-core/kafka-supervisor-operations.md index 8504ced595b3..b76a80f8cb9b 100644 --- a/docs/development/extensions-core/kafka-supervisor-operations.md +++ b/docs/development/extensions-core/kafka-supervisor-operations.md @@ -5,6 +5,9 @@ sidebar_label: "Apache Kafka operations" description: "Reference topic for running and maintaining Apache Kafka supervisors" --- +import Tabs from '@theme/Tabs'; +import TabItem from '@theme/TabItem'; + + + + - ```shell curl --request POST "http://ROUTER_IP:ROUTER_PORT/druid/indexer/v1/supervisor/social_media/resetOffsets" @@ -159,7 +163,8 @@ curl --request POST "http://ROUTER_IP:ROUTER_PORT/druid/indexer/v1/supervisor/so --data-raw '{"type":"kafka","partitions":{"type":"end","stream":"ads_media_foo|ads_media_bar","partitionOffsetMap":{"ads_media_foo:0": 3, "ads_media_bar:1": 12}}}' ``` - + + ```HTTP POST /druid/indexer/v1/supervisor/social_media/resetOffsets HTTP/1.1 @@ -178,10 +183,12 @@ Content-Type: application/json } } ``` + The above operation will reset offsets for `ads_media_foo` partition 0 and `ads_media_bar` partition 1 to offsets 3 and 12 respectively. After a successful reset, when the supervisor's tasks restart, they will resume reading from `{"ads_media_foo:0": 3, "ads_media_foo:1": 10, "ads_media_bar:0": 20, "ads_media_bar:1": 12}`. - + + #### Sample response