AbsaOSS / AbsaOSS/py2k

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

Aberta
#51 0 comentários 0 reações 0 responsáveis Ver no GitHub
enhancement
Linguagem predominante
Python
Estrelas
13
Forks
2
Métricas de merge de PRs
Nenhum PR com merge em 30d

Descrição

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)
```

Guia de contribuição

Abrir o guia de contribuição

Avaliação

Esta issue ainda não foi avaliada.

Receba novas issues na sua caixa de entrada

Um resumo curto de issues do GitHub para quem está começando.