Kafka Streams runner: lifecycle management for runner-created topics
Maintainer thường phản hồi trong vòng 1 ngày
Chưa có ai nhận issue này.
Đánh giá
- Độ khó
- 5/5
- Thời gian dự kiến
- Hơn một tuần
- Mức phù hợp với người mới
- 35/100
- Loại issue
- Tính năng
- Độ rõ ràng
- Khá rõ ràng
- Mức độ hoạt động
- Ít trao đổi
- Công nghệ
- java, kafka
- Lĩnh vực
- stream-processing
Hướng nghiên cứu
Bắt đầu bằng cách đọc PR #39546 về hành vi hiện tại của các topic của Kafka Streams runner và issue #18479 để hiểu bối cảnh rộng hơn. Xác định các yêu cầu về vòng đời cho các lệnh --create-topics, normal run và --delete-topics, với việc hoàn thành được chứng minh bằng khả năng để các operator tạo và xóa rõ ràng các topic do runner tạo ra.
Do mô hình lập chỉ mục viết ra từ nội dung của issue.
Mô tả
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.
- Ngôn ngữ chính
- Java
- Star
- 8.7k
- Fork
- 4.8k
- Merge trung bình
- 2 ngày 4 giờ
- Pull request đã merge (30 ngày)
- 334
Chuẩn bị môi trường
- Không có Dockerfile hay tệp Docker Compose
- Có mẫu pull request
- Đọc hướng dẫn đóng góp
Bắt đầu từ đâu
- Đọc hết issue, rồi đọc hướng dẫn đóng góp của dự án.
- Bình luận trên issue rằng bạn sẽ nhận — tránh hai người làm cùng một việc.
- Fork repository và làm thay đổi trên một nhánh.
- Mở pull request có tham chiếu số hiệu của issue.
Issue khác của apache/beam
-
[Failing Test]: BigqueryClient.queryUnflattened fails BigQuery ITs on a transient 503Có thể đã có người làm @mxtymoshyk đã nhận 13 ngày trước. Đang mở
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 77/100
Maintainer thường phản hồi trong vòng 1 ngày
-
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 68/100
apache/beam#39624 · 2 reaction ·
Maintainer thường phản hồi trong vòng 1 ngày
-
[Bug]: PubsubIO used in batch incorrect batch cutoff sizeCó thể đã có người làm @1fanwang đã nhận 74 ngày trước. Đang mởbug io P3 pinned pubsub
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 78/100
apache/beam#28011 · 4 bình luận ·
Maintainer thường phản hồi trong vòng 1 ngày
-
build P3 sub-task
Độ khó 1/5 Dưới một giờ Mức phù hợp với người mới 68/100
Maintainer thường phản hồi trong vòng 1 ngày
-
bug gcp io java P3
Độ khó 1/5 Dưới một giờ Mức phù hợp với người mới 65/100
Maintainer thường phản hồi trong vòng 1 ngày
Issue tương tự
-
Marketplace time-zone issueĐang mởbug main ui
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 78/100
openhab/openhab-webui#4671 ·
Maintainer thường phản hồi trong vòng 1 ngày
-
enhancement
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 64/100
NearVanilla/IceCream#109 ·
Maintainer thường phản hồi trong vòng 1 ngày
-
getRawTextContent() returns the lines of every page in reverse order (bottom to top) since 4.0.3Đang mở
Độ khó 1/5 1-3 giờ Mức phù hợp với người mới 90/100
-
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 82/100
bancolombia/bin-stash#79 ·
-
bug
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 82/100
Maintainer thường phản hồi trong vòng 1 ngày