-
Notifications
You must be signed in to change notification settings - Fork 92
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
DBZ-8634 Milvus sink #156
DBZ-8634 Milvus sink #156
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.
I only skimmed through the PR, so maybe I'm missing something, but why is all the Pulsar and related stuff (bookkeeper, zookeeper) needed? Or all this stuff will be removed (as a remnant from copying Pulsar module)?
7f29ce5
to
d4426bb
Compare
@vjuranek The PR was cleaned and the implementation is at MVP level. Please take a look. |
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.
Few minor comments, but over LGTM, nice work!
debezium-server-milvus/src/main/java/io/debezium/server/milvus/MilvusChangeConsumer.java
Show resolved
Hide resolved
debezium-server-milvus/src/main/java/io/debezium/server/milvus/MilvusChangeConsumer.java
Show resolved
Hide resolved
debezium-server-milvus/src/main/java/io/debezium/server/milvus/MilvusSchema.java
Outdated
Show resolved
Hide resolved
debezium-server-milvus/src/main/java/io/debezium/server/milvus/MilvusChangeConsumer.java
Show resolved
Hide resolved
Co-authored-by: Vojtěch Juránek <[email protected]>
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.
@vjuranek Please check the answers
debezium-server-milvus/src/main/java/io/debezium/server/milvus/MilvusChangeConsumer.java
Show resolved
Hide resolved
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.
LGTM (once the compilation failure is fixed)
Co-authored-by: Vojtěch Juránek <[email protected]>
Co-authored-by: Vojtěch Juránek <[email protected]>
No description provided.