HTTP client treats a consumer group as a plain consumer

オープン 初心者向け
  • 何か問題がありますか？
#4,408 コメント 2 件 リアクション 0 件 担当者 0 名 GitHub で見る

メンテナーはふだん 1 日以内に返信

@mohitduhan19 がすでに取り組んでいます。

2026年10月15日 から。

評価

難易度
2/5
見積もり時間
1〜3時間
初心者へのやさしさ
75/100
issue の種類
バグ
明瞭さ
明確に書かれている
活発さ
活発
技術スタック
rust
領域
api, backend

調査の方向性

core/sdk/src/http/consumer_offsets.rsから始め、issueが先例として挙げている#4392のrefuse_external_groupを読みます。store_consumer_offset、get_consumer_offset、delete_consumer_offset、poll_messagesのHTTPクライアントの処理経路をたどります。それぞれがConsumerKind::Consumer以外の種類をFeatureUnavailableで拒否し、グループを通常のコンシューマーとして黙って扱わない状態になれば完了です。

索引モデルが issue の本文から書いたものです。

説明

bug rust server
Bug description

The REST API cannot name a consumer kind. Consumer.kind is #[serde(skip)], and the server builds a plain consumer (Consumer::new) from an HTTP request. An HTTP client can pass Consumer::group(..) to store_consumer_offset, get_consumer_offset, delete_consumer_offset or poll_messages. The call then acts on the plain consumer with the group's id, and no error tells the caller. Join and leave already return FeatureUnavailable over HTTP, so a group cannot work there.

Expected: the HTTP client refuses every kind except ConsumerKind::Consumer with FeatureUnavailable, as #4392 does for ConsumerKind::ExternalGroup (refuse_external_group in core/sdk/src/http/consumer_offsets.rs). This changes behavior for an HTTP caller that passes a group today. Raised in the review of #4392.

Affected area / component

Rust SDK, Iggy server

Reproduction
  1. Build an IggyClient with the HTTP transport.
  2. Send 10 messages to partition 0 of a topic.
  3. Store offset 5 with Consumer::group(Identifier::numeric(1)?) on partition 0.
  4. Read the offset with Consumer::new(Identifier::numeric(1)?). It returns 5.
主要言語
Rust
スター
5.2k
フォーク
516
平均マージ
2日 17時間
マージ済み PR（30日）
155

環境構築

Codespaces で開く

このプロジェクトの開発コンテナを、あなたの GitHub アカウントでブラウザ上に起動します。

はじめの一歩

  1. issue を最後まで読み、次にプロジェクトのコントリビューションガイドを読みます。
  2. 着手することを issue にコメントします — 二人が同じ作業をするのを防げます。
  3. リポジトリをフォークし、ブランチを切って変更します。
  4. issue 番号を参照したプルリクエストを送ります。

apache/iggy のほかの issue

apache/iggy の issue をすべて見る

似ている issue

Rust の issue をもっと見る

新しい issue をメールで受け取る

初心者向けの GitHub issue を短くまとめたダイジェスト。