Open
Description
- Missing old class ydb.iam.auth.IamTokenCredentials #67
- Send one message to topic by experimental code in topic branch #70
- Simplify topic writer with use state changed event instead of asyncio.Lock #148
- Add topics control plane #127
- Close grpc streams with close reader/writer #173
- Support flush to writer #133
- Support flush to reader #132
- Add read message by one message #129
- Close reader/writer by del without flush #189
- Add send auth token to writer #139
- Add send auth token to reader #138
- Add topic commit to reader #128
- Support codecs to writer #134
- Support codecs for reader #135
- Stop external code waits on topic reader/writer for non repeatable errors #188
- Set result of write message when receive ack from server #245
- Add custom topic reader settings instead of topic name only to PublicReaderSettings and public interface #241
- Implement sync wrapper for topic reader #145
- Add alter topic method #265
- Add method commit_offset
- Add logs to topic services #185
- Support retry policy to reader #130
- Support retry policy to writer #131
- Support internal buffer limit by message count for writer #136
- Support internal buffer limit by memory for writer #137
- Implement partition stats for topic reader #147
- Implement efficient message batching for writer #142
- Implement wait_init for topic writer #146
- Add serializer to writer #140
- Add deserializer to reader #141
- Check seqno on writer retries #143
- Support max_messages/max_bytes in reader.receive_batch
- Add events: on start/stop partitions, graceful, hard