Skip to content
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

Add example of data streaming with apache kafka + apache flink #353

Merged
merged 3 commits into from
Mar 15, 2024

Conversation

surister
Copy link
Contributor

@surister surister commented Mar 7, 2024

About

Illustrate how to use Apache Flink through its PyFlink interface, together with Apache Kafka and CrateDB.

Copy link
Member

@amotl amotl left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Excellent job, I love it.

application/streaming-apache-kakfa-flink/Dockerfile Outdated Show resolved Hide resolved
@surister surister marked this pull request as ready for review March 10, 2024 19:55
requirements.txt Outdated Show resolved Hide resolved
application/apache-kafka-flink-streaming/.env Outdated Show resolved Hide resolved
@surister surister force-pushed the streaming-kafka-flink branch 2 times, most recently from 1bee60d to df13db1 Compare March 12, 2024 16:54
@surister surister force-pushed the streaming-kafka-flink branch from df13db1 to a11deb1 Compare March 12, 2024 16:56
Copy link
Member

@amotl amotl left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Excellent patch, thank you very much. Just added some comments/suggestions about a few nits, and also adding @matriv as reviewer.

application/apache-kafka-flink-streaming/README.md Outdated Show resolved Hide resolved
application/apache-kafka-flink-streaming/README.md Outdated Show resolved Hide resolved
application/apache-kafka-flink-streaming/README.md Outdated Show resolved Hide resolved
application/apache-kafka-flink-streaming/README.md Outdated Show resolved Hide resolved
application/apache-kafka-flink-streaming/README.md Outdated Show resolved Hide resolved
application/apache-kafka-flink-streaming/README.md Outdated Show resolved Hide resolved
application/apache-kafka-flink-streaming/README.md Outdated Show resolved Hide resolved
application/apache-kafka-flink-streaming/README.md Outdated Show resolved Hide resolved
@amotl amotl requested a review from matriv March 13, 2024 06:16
Copy link
Contributor

@matriv matriv left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Thx a lot for this effort @surister !

Left a couple more comments on top of the ones posted by @amotl .

application/apache-kafka-flink-streaming/README.md Outdated Show resolved Hide resolved
Copy link
Member

@amotl amotl left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Other than a few minor suggestions which could be adjusted, approving this. Thanks again!

@surister surister merged commit 5aadb16 into crate:main Mar 15, 2024
@surister
Copy link
Contributor Author

Thanks for the thorough review, all fixes have been applied 👍

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

3 participants