-
Notifications
You must be signed in to change notification settings - Fork 2.3k
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
Kafka Connect: Runtime distribution with integration tests #10739
Conversation
Can we please split into two PRs. one for adding runtime distributions and one for integration tests? |
The integration tests depend on the runtime. |
I know. We can review and merge the runtime PR first and then rebase the integration test PR? |
The integration tests are testing the runtime, so I feel they belong together. Also, the runtime build is just the |
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.
Overall, looks good. I think there are some minor issues with assets/logos and it would be great if we could run the integration tests without having to manually start the compose.
224700b
to
39d0310
Compare
entrypoint: mc mb /data/bucket | ||
|
||
iceberg: | ||
image: tabulario/iceberg-rest |
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.
Should we really add this dependency?
I am not sure about the future roadmap of this project.
Can we use some OSS implementation of the catalog?
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'm not sure if there is a better alternative but I'm happy to switch if there is one. @danielcweeks do you have concerns relying on this image?
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.
This is currently used by a number of projects as a test depending (python,rust,trino) and is fine for now. We've discussed moving this into the test fixtures in core and I'll work with @Fokko to get that done and we can move the test dependencies separately.
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.
Thanks for the update.
It would be nice to maintain and publish this image under OSS iceberg account 👍
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.
+1
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 can help on the DockerHub "seat" for apache/iceberg (I just did that for the new openserverless podling). Just let me know 😄
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.
Yes.
With that account we can even publish some more test image like Trino, kafaka-connect, Spark etc.
And we can maintain these images in Iceberg repo test module or as a separate subproject "Iceland - A playground for Iceberg"
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.
Thanks @jbonofre! That was one of the biggest outstanding issues because we don't currently produce any images as a project.
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.
@danielcweeks happy to help ! 😄
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
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.
Integration tests can be refactored to adopt any catalog instead of hardcoded rest catalog. But that is not a blocker for merging this PR.
Thanks for the reviews @danielcweeks , @fqaiser94 , and @ajantha-bhat !! |
This PR is the next stage in submitting the Kafka Connect Iceberg sink connector, and is a follow up to #8701, #9466, #9641, and #10351.
This adds building of runtime distributions plus some integration tests. There are two runtime distributions, one that bundles the HMS client and related libraries, and one that does not. The one without the HMS client is much smaller and also doesn't have dependencies with critical security vulnerabilities. Repositories like Confluent Hub require connectors be free of critical vulnerabilities.
Remaining tasks are listed in #10740.