Skip to content

Comments

Check from v3 API#14

Open
flavono123 wants to merge 1 commit intopacketloop:developfrom
flavono123:feature/upgrade-comp-to-vthree
Open

Check from v3 API#14
flavono123 wants to merge 1 commit intopacketloop:developfrom
flavono123:feature/upgrade-comp-to-vthree

Conversation

@flavono123
Copy link

  • Use v3 endpoint
  • Add timestamps to partition lags
  • Ignore __consumer_offsets topic when collect topic offsets, offset_topics in the cluster response seems deprecated
  • Submit offsets
    • Split methods by offset types, _submit_offsets_from_json() to _submit_offsets_for_topic/consumer()
    • Pass offsets(list) or topic_dict each rather than a response

Signed-off-by: Hansuk flavono123@gmail.com

- Use v3 endpoint
- Add timestamps to partition lags
- Ignore `__consumer_offsets` topic when collect topic offsets,
  offset_topics in the cluster response seemed deprecated
- Submit offsets
  - Split methods by offset types, `_submit_offsets_from_json()` to
  `_submit_offsets_for_topic/consumer()`
  - Pass offsets(list) or topic_dict each rather than a response

Signed-off-by: Hansuk <flavono123@gmail.com>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant