Kafka Streams runner: lifecycle management for runner-created topics
メンテナーはふだん 1 日以内に返信
まだ誰も着手していません。
評価
- 難易度
- 5/5
- 見積もり時間
- 1週間以上
- 初心者へのやさしさ
- 35/100
- issue の種類
- 機能追加
- 明瞭さ
- おおむね明確
- 活発さ
- 静か
- 技術スタック
- java, kafka
調査の方向性
まず、Kafka Streams runner の現在のトピック動作について PR #39546 を読み、より広い背景について issue #18479 を読みます。--create-topics、normal run、--delete-topics コマンドのライフサイクル要件を定義し、オペレーターが runner によって作成されたトピックを明示的に作成および削除できることによって完了を実証します。
索引モデルが issue の本文から書いたものです。
説明
Summary
The Kafka Streams runner creates the internal topics a pipeline needs implicitly, when the job starts (https://github.com/apache/beam/pull/39546).
It may be better to make that explicit and give the topics a lifecycle, so an operator can create them ahead of time and clean them up afterwards:
# just create topics
java -cp ... my.class --runner=KafkaStreams [... other opts ...] --create-topics
# run
java -cp ... my.class --runner=KafkaStreams [... other opts ...]
# delete runner-created topics
java -cp ... my.class --runner=KafkaStreams [... other opts ...] --delete-topics
Part of #18479.
- 主要言語
- Java
- スター
- 8.7k
- フォーク
- 4.7k
- 平均マージ
- 2日 2時間
- マージ済み PR（30日）
- 311
環境構築
- Dockerfile・Docker Compose ファイルなし
- プルリクエストのテンプレートあり
- コントリビューションガイドを読む
はじめの一歩
- issue を最後まで読み、次にプロジェクトのコントリビューションガイドを読みます。
- 着手することを issue にコメントします — 二人が同じ作業をするのを防げます。
- リポジトリをフォークし、ブランチを切って変更します。
- issue 番号を参照したプルリクエストを送ります。
apache/beam のほかの issue
-
[Bug]: DeferredSeries.duplicated() raises WontImplementError due to incorrect column indexing対応中かも @derrickaw が今日担当しました。 オープンbug P2 python
難易度 2/5 1〜3時間 初心者へのやさしさ 78/100
apache/beam#40814 · コメント 1 件 · 担当者 1 名 ·
メンテナーはふだん 1 日以内に返信
-
[Failing Test]: BigqueryClient.queryUnflattened fails BigQuery ITs on a transient 503対応中かも @mxtymoshyk が 2 日前に担当しました。 オープン
難易度 2/5 1〜3時間 初心者へのやさしさ 77/100
メンテナーはふだん 1 日以内に返信
-
[Feature Request]: Support Protobuf 7.x in Python SDK対応中かも @sofiathoren が 13 日前に担当しました。 オープンP2 python
難易度 2/5 1〜3時間 初心者へのやさしさ 62/100
メンテナーはふだん 1 日以内に返信
-
難易度 2/5 1〜3時間 初心者へのやさしさ 68/100
apache/beam#39624 · リアクション 2 件 ·
メンテナーはふだん 1 日以内に返信
-
[Bug]: PubsubIO used in batch incorrect batch cutoff size対応中かも @1fanwang が 63 日前に担当しました。 オープンbug io P3 pinned pubsub
難易度 2/5 1〜3時間 初心者へのやさしさ 78/100
apache/beam#28011 · コメント 4 件 ·
メンテナーはふだん 1 日以内に返信
似ている issue
-
agent:working bug follow-up lane:auto
難易度 2/5 1〜3時間 初心者へのやさしさ 72/100
Sanne/incus-spawn#1765 · コメント 2 件 ·
メンテナーはふだん 1 日以内に返信
-
bug
難易度 2/5 1〜3時間 初心者へのやさしさ 78/100
メンテナーはふだん 1 日以内に返信
-
Mend: dependency security vulnerability untriaged
難易度 2/5 1〜3時間 初心者へのやさしさ 63/100
opensearch-project/data-prepper#7219 ·
メンテナーはふだん 1 日以内に返信
-
難易度 2/5 1〜3時間 初心者へのやさしさ 83/100
メンテナーはふだん 1 日以内に返信
-
難易度 2/5 1〜3時間 初心者へのやさしさ 70/100
PaperMC/docs#824 · コメント 1 件 · リアクション 1 件 ·
メンテナーはふだん 1 日以内に返信