entity framework create entities from existed db
dotnet ef dbcontext scaffold "server=localhost;user=user;password=1234;persistsecurityinfo=True;database=osa_market_8;port=3308;" MySql.Data.EntityFrameworkCore -o Model -c "AdventureContext" -f -d -v
kafka конспект однако
------------------------ part 1 --------------------- schema evolution 1: avro - в сообщении содержится схема данных. предоставляет API для сериализации данных соответственно схеме и десериализации по схеме. exactly once processing: тут проблема в том что нет контроля над тем какой partition будет назначен. есть две стратегии: range: round robin: rebalance listener: случай когда consumer group coordinator запустил rebalance и consumer, обработавший часть сообщений хочет commit offset. чтобы это сделать надо знать: how to commit a particular offset? how to know that a rebalance is triggered? ConsumerRebalanceListener onPartitionsRevoked - будет вызван перед переключением partition. onPartitionsAssigned - будет вызвано после назначения partition и перед передачей сообщений. offset management: current offset: kafka broker у себя хранит указатель на на отправленные сообщения клонкретному consumer. maintain offset from which send next banch of mess
Комментарии
Отправить комментарий