AbsaOSS / AbsaOSS/py2k

Users should be able to update the topic on the writer to a new topic

未關閉
#51 0 則留言 0 個 reaction 已指派 0 人 在 GitHub 檢視
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 還沒有評估資料。

把新 issue 寄到你的電子郵件信箱

精選適合新手參與的 GitHub issue 摘要。