Users should be able to update the topic on the writer to a new topic
未關閉
enhancement
- 主要語言
- Python
- 星號
- 13
- 分支
- 2
- PR 合併指標
- 30 天內沒有已合併 PR
描述
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
```python
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)
```
貢獻指南
評估
這個 Issue 還沒有評估資料。