Skip to content

KafkaSkipModel should respect @producer.suppress activation #79

@stefan-cardnell-rh

Description

@stefan-cardnell-rh

@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.

  1. When @producer.suppress is used without arguments then it applies globally, so kafka_skip=True can be set unconditionally.
  2. 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.
  3. Don't forget to update KafkaConnectQueryset

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions