-
Notifications
You must be signed in to change notification settings - Fork 533
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[INLONG-10287][Agent] Update the Redis Source #10801
Conversation
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Hello @emptyOVO, thank you for submitting a PR to InLong 💖 We will respond as soon as possible ⏳
This seems to be your first PR 🌠 Please be sure to follow our Contribution Guidelines.
If you have any questions in the meantime, you can also ask us on the InLong Discussions 🔍
...ng-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java
Outdated
Show resolved
Hide resolved
...ng-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java
Show resolved
Hide resolved
@emptyOVO please click |
got it |
…bscribed a key operation, it filters the key we want and jedis is used to obtain the key data
...ng-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java
Show resolved
Hide resolved
…plicator to subscribe event and filtering data by command
Fixes #10287
Motivation
Update the Redis source for agent
Modifications
Modify TaskProfileDto and RedisTask to accept and parse the configuration.
Add RedisTask, RedisInstance, and RedisSource classes
Provide Unit Test
Verifying this change