ActiveRecordConsumer currently consumes everything from a topic. This could be devastating when handling large topics and you want to skip the processing of some of the messages that you don't care.
It would be great if we are allowed to override a predicate method e.g. process_payload? to allow conditionally skip some of the messages going through the consumer.
csingh
commented
3 years ago
ActiveRecordConsumercurrently consumes everything from a topic. This could be devastating when handling large topics and you want to skip the processing of some of the messages that you don't care.It would be great if we are allowed to override a predicate method e.g.
process_payload?to allow conditionally skip some of the messages going through the consumer.