You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@bahir.apache.org by "João Boto (Jira)" <ji...@apache.org> on 2023/06/07 09:05:00 UTC
[jira] [Commented] (BAHIR-322) Continuous Non-stop Kudu Connector for Flink
[ https://issues.apache.org/jira/browse/BAHIR-322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17730016#comment-17730016 ]
João Boto commented on BAHIR-322:
---------------------------------
Hi [~sagitchen], having the option is a great idea.. will you contribute with the code?
> Continuous Non-stop Kudu Connector for Flink
> ---------------------------------------------
>
> Key: BAHIR-322
> URL: https://issues.apache.org/jira/browse/BAHIR-322
> Project: Bahir
> Issue Type: Improvement
> Components: Flink Streaming Connectors
> Reporter: Wei Chen
> Priority: Minor
>
> Hi Team,
> When I was using Bahir Kudu Connector for Flink to build data pipeline, I found it didn't support continuously non-stop reading data in kudu tables. Considering Kudu doesn't support CDC, it sounds like fair enough not to have this. However, the idea in [https://docs.confluent.io/kafka-connectors/kudu/current/source-connector/overview.html#incremental-query-modes] inspired me to have a continuous, non-stop kudu connector for Flink, so I've built one with the same idea in [https://github.com/eBay/flink-kudu-streaming-connector] .
> I'd like to see if any chances this feature is able to merged into one part of Bahir Kudu Connector. :)
> Let me know if you have any comments or suggestion.
>
> Best Regards
--
This message was sent by Atlassian Jira
(v8.20.10#820010)