You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
We may wish to provide a way for Python Producers to send an initial set of data events to their topics.
For instance, this can be the case when using Python producers to send Django model instance changes to a topic instead of using Debezium source connectors. Debezium may not meet our requirements, especially when related-table data is needed in the event.
Ideas/considerations:
Provide a subclass/decorator which allows defining an initialize method on the Producer, which can be called for the Producer to create initial data events.
Run this initialize method during kafka startup (kafka_consume) or provide another management command for event initialization.
(Optional) Provide some way for Producers to track their sent initial events, to not send them if they are initialised multiple times.
The text was updated successfully, but these errors were encountered:
We may wish to provide a way for Python Producers to send an initial set of data events to their topics.
For instance, this can be the case when using Python producers to send Django model instance changes to a topic instead of using Debezium source connectors. Debezium may not meet our requirements, especially when related-table data is needed in the event.
Ideas/considerations:
subclass
/decorator
which allows defining aninitialize
method on the Producer, which can be called for the Producer to create initial data events.initialize
method during kafka startup (kafka_consume
) or provide another management command for event initialization.The text was updated successfully, but these errors were encountered: