Я использую RocksDB в одном из моих приложений.
В основном один поток получает данные (поток потока kafka и, следовательно, записывает данные в один из разделов rockdsDB), а другой поток читает тот же самый rockSDB (и тот же раздел), обрабатывает и удаляет после обработки.
Ситуация выглядит так:
Thread-1: (a kafka stream ) writes into RocksDB (say 0_1 partition)
Thread-1-process-thread: (plain thread which is created by "Thread-1") reads the data , process and deletes.
Мой вопрос:
- Поддерживает ли RocksDB одновременную запись без программа беспокоится о повреждении данных?
Например, Поток-1 может записывать данные (например, раздел 0_1) и в то же время Поток-1-процесс-поток (для того же раздела, 0_1) пытается удалить данные? Возможно ли это?
Я ссылался на онлайн-документацию, но не уверен, что этот сценарий описан.