feat: added action kafka_notify #621
Open
Conversation
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Added a new action called kafka_notify to contrast with pg_notify This action would allow an event to be posted to a Kafka topic for other consumers.
|
|
||
| class KafkaNotify: | ||
| """The Kafka notify action used to send messages to a Kafka topic | ||
| The required arguments are: |
There was a problem hiding this comment.
If this have mandatory arguments they should be declared in the __init__ signature.
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Added a new action called kafka_notify to contrast with pg_notify This action would allow an event to be posted to a Kafka topic for other consumers.
To generate arbitrary sized blobs we have enhanced our generic source plugin to use the new collection you would have to build an image with those changes
Then you can use the updated collection in these 2 rule books
To test the Activations first create the Listener Activation and then the Generator Activation