[jira] [Commented] (FLINK-27156) [FLIP-171] MongoDB implementation of Async Sink

[ https://issues.apache.org/jira/browse/FLINK-27156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17530608#comment-17530608 ] Almog Tavor commented on FLINK-27156: - [~martijnvisser] Sounds great, but I'd like t

[jira] [Commented] (FLINK-27156) [FLIP-171] MongoDB implementation of Async Sink

[ https://issues.apache.org/jira/browse/FLINK-27156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17525761#comment-17525761 ] Almog Tavor commented on FLINK-27156: - [~martijnvisser] That's fine by me, but is th

[jira] [Created] (FLINK-27156) [FLIP-171] MongoDB implementation of Async Sink

Almog Tavor created FLINK-27156: --- Summary: [FLIP-171] MongoDB implementation of Async Sink Key: FLINK-27156 URL: https://issues.apache.org/jira/browse/FLINK-27156 Project: Flink Issue Type: New

[jira] [Commented] (FLINK-26751) [FLIP-171] Kafka implementation of AsyncSinkBase

[ https://issues.apache.org/jira/browse/FLINK-26751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17512530#comment-17512530 ] Almog Tavor commented on FLINK-26751: - I think this raises a problematic issue with

[jira] [Commented] (FLINK-26751) [FLIP-171] Kafka implementation of AsyncSinkBase

[ https://issues.apache.org/jira/browse/FLINK-26751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17510136#comment-17510136 ] Almog Tavor commented on FLINK-26751: - [~martijnvisser] As for my understanding the

[jira] [Updated] (FLINK-26751) [FLIP-171] Kafka implementation of AsyncSinkBase

[ https://issues.apache.org/jira/browse/FLINK-26751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Almog Tavor updated FLINK-26751: Description: *User stories:* Standardize the Kafka connector to implement AsyncSinkBase. *Scope:*

[jira] [Updated] (FLINK-26751) [FLIP-171] Kafka implementation of Async Sink

[ https://issues.apache.org/jira/browse/FLINK-26751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Almog Tavor updated FLINK-26751: Description: *User stories:* Standardize the Kafka connector . *Scope:* * Implement an asynchron

[jira] [Updated] (FLINK-26751) [FLIP-171] Kafka implementation of AsyncSinkBase

[ https://issues.apache.org/jira/browse/FLINK-26751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Almog Tavor updated FLINK-26751: Summary: [FLIP-171] Kafka implementation of AsyncSinkBase (was: [FLIP-171] Kafka implementation o

[jira] (FLINK-26751) [FLIP-171] Kafka implementation of Async Sink

[ https://issues.apache.org/jira/browse/FLINK-26751 ] Almog Tavor deleted comment on FLINK-26751: - was (Author: almogtavor): [~martijnvisser] Maybe I just didn't understand something right. Currently, the Kafka sink isn't implementing `AsyncSin

[jira] [Commented] (FLINK-26751) [FLIP-171] Kafka implementation of Async Sink

[ https://issues.apache.org/jira/browse/FLINK-26751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17510128#comment-17510128 ] Almog Tavor commented on FLINK-26751: - [~martijnvisser] Maybe I just didn't understa

[jira] [Updated] (FLINK-26751) [FLIP-171] Kafka implementation of Async Sink

[ https://issues.apache.org/jira/browse/FLINK-26751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Almog Tavor updated FLINK-26751: Description: *User stories:* As a Flink user, I’d like to use Kafka as a sink for my data pipeline

[jira] [Created] (FLINK-26751) [FLIP-171] Kafka implementation of Async Sink

Almog Tavor created FLINK-26751: --- Summary: [FLIP-171] Kafka implementation of Async Sink Key: FLINK-26751 URL: https://issues.apache.org/jira/browse/FLINK-26751 Project: Flink Issue Type: New F