CCAP-59: Added session_id for KafkaMessage batches in db_producer

flipp-oss / deimos

Framework to work with Kafka, Avro and ActiveRecord

Other

59 stars 22 forks source link

CCAP-59: Added session_id for KafkaMessage batches in db_producer #51

Closed george-ma closed 1 year ago

george-ma commented 4 years ago

Created migration to add an (indexed) session_id to the kafka_messages table Updated db_producer logic to update the session_id when a batch of messages are received (this session_id is used in the DELETES) Updated .md files (version breaking change)