@producer.suppress currently only works with Python Producers.
However it could also be extended to work with debezium source connectors; KafkaSkipModel.save could simply check the producer.Suppress status and set kafka_skip=True if it's activated; removing the need to manually manage the attribute.
- When
@producer.suppress is used without arguments then it applies globally, so kafka_skip=True can be set unconditionally.
- When
@producer.suppress is used with a topic argument it's not known within the context of KafkaSkipModel.save if the suppression applies. Therefore, an idea could be to extend producer.suppress to take a list of Model types for which to set kafka_skip=True automatically.
- Don't forget to update
KafkaConnectQueryset