ektravel commented on code in PR #16276: URL: https://github.com/apache/druid/pull/16276#discussion_r1577154175
########## docs/ingestion/supervisor.md: ########## @@ -309,23 +311,23 @@ The following table lists `detailedState` values and their corresponding `state` On each iteration of the supervisor's run loop, the supervisor completes the following tasks in sequence: -1. Fetch the list of units of parallelism, such as Kinesis shards or Kafka partitions, and determine the starting sequence number or offset for each unit (either based on the last processed sequence number or offset if continuing, or starting from the beginning or ending of the stream if this is a new stream). +1. Fetch the list of partitions and determine the starting offset for each partition. Druid determines the offset based on the last processed offset if continuing, or it starts from the beginning or end of the stream if it's a new stream. Review Comment: Good call. Updated. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
