Users should be able to update the topic on the writer to a new topic
Chưa có ai nhận issue này.
Đánh giá
- Độ khó
- 3/5
- Thời gian dự kiến
- 1-2 ngày
- Mức phù hợp với người mới
- 35/100
Hướng nghiên cứu
KafkaWriter là entry point được nêu trong issue; hãy bắt đầu bằng cách tìm implementation của nó và đọc cách topic hiện tại được lưu trữ và sử dụng trong quá trình ghi. So sánh hai API được đề xuất và kiểm tra các test hiện có của writer, nếu có. Công việc được xem là hoàn tất khi một writer có thể gửi các lần ghi liên tiếp đến các topic khác nhau trong khi tái sử dụng cấu hình của producer và schema registry.
Do mô hình lập chỉ mục viết ra từ nội dung của issue.
Mô tả
For example, if I want to write raw data and processed data onto Kafka, into two separate topics, but with the same producer config and schema registry config.
Suggested API
from py2k.writer import KafkaWriter
writer = KafkaWriter(topic='topic1',
producer_config=some_producer_config,
schema_registry_config=some_sr_config)
writer.write(some_records)
writer.topic = 'new_topic'
# OR
writer.update_topic('new_topic')
writer.write(other_records)
- Ngôn ngữ chính
- Python
- Star
- 13
- Fork
- 2
- Chỉ số merge pull request
- Không có pull request nào được merge trong 30 ngày
Chuẩn bị môi trường
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 AbsaOSS/py2k
-
bug
Độ khó 3/5 1-2 ngày Mức phù hợp với người mới 42/100
-
Bumping version incorrectly label **version** in **init**.py of fileCó thể làm lại được @DanWertheimer đã nhận 1819 ngày trước và không có pull request nào đang mở. Đang mởbug good first issue
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 25/100
-
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 48/100
-
Automated integration testsĐang mở
Độ khó 5/5 Hơn một tuần Mức phù hợp với người mới 15/100
-
enhancement
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 48/100
Issue tương tự
-
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 76/100
PedestrianDynamics/pyFDS-Evac#199 ·
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 65/100
521xueweihan/HelloGitHub#3790 ·
-
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 78/100
sandialabs/atlas-ui-3#978 ·
Maintainer thường phản hồi trong vòng 1 ngày
-
area: tests perceived difficulty: 2
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 72/100
Nitjsefnie-Harness-Commons/daedalus#1255 ·
Maintainer thường phản hồi trong vòng 1 ngày
-
hf-audiolm-qwen: `generate_until` hardcodes `.to("cuda")` and aborts on non-CUDA acceleratorsĐang mở
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 86/100
EleutherAI/lm-evaluation-harness#4256 ·
Maintainer thường phản hồi trong vòng 1 ngày