flipp-oss / deimos

Framework to work with Kafka, Avro and ActiveRecord
Other
59 stars 22 forks source link

- Added config to dedupe messages in the DB producer. #26

Closed dorner closed 4 years ago

dorner commented 4 years ago

Pull Request Template

Description

This adds a feature to allow the DB producer to dedupe (compact) messages in a single batch. This is based on the finding that often in Rails we will update objects multiple times, which KafkaSource will translate into multiple messages. This can cut down the number of messages actually sent by a significant amount.

This also adds the ability to log messages per topic or globally.

Type of change

Please delete options that are not relevant.

How Has This Been Tested?

Primarily locally for now - want to release a beta version to test in production.

Checklist:

dorner commented 4 years ago

@colinmroberts addressed comments and pushed a couple of fixes.