CCOL-1451: Added post_process method to db_poller

flipp-oss / deimos

Framework to work with Kafka, Avro and ActiveRecord

Other

59 stars 22 forks source link

CCOL-1451: Added post_process method to db_poller #162

Closed dkharytonenko-blackbird closed 1 year ago

dkharytonenko-blackbird commented 1 year ago

Description

To post-process batches sent to Kafka you can define one additional method in your producer class.

Type of change

Additional functionality

Please delete options that are not relevant.

[x] New feature (non-breaking change which adds functionality)

How Has This Been Tested?

Not tested. Changes include one line of code with if condition

dorner commented 1 year ago

@dkharytonenko-blackbird @harsha-flipp Can we generalize this to post-processing any batch of messages - i.e. adding this as a default method to ActiveRecordProducer and calling it explicitly from send_events?