[jira] [Created] (FLINK-36017) Support Passing Metadata to Formats in KafkaDynamicSink

Kevin Lam created FLINK-36017: - Summary: Support Passing Metadata to Formats in KafkaDynamicSink Key: FLINK-36017 URL: https://issues.apache.org/jira/browse/FLINK-36017 Project: Flink Issue Type:

[jira] [Commented] (FLINK-22748) Allow dynamic target topic selection in SQL Kafka sinks

[ https://issues.apache.org/jira/browse/FLINK-22748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868094#comment-17868094 ] Kevin Lam commented on FLINK-22748: --- Hi I've taken some time to build upon [~nicholasj

[jira] [Commented] (FLINK-22748) Allow dynamic target topic selection in SQL Kafka sinks

[ https://issues.apache.org/jira/browse/FLINK-22748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17866795#comment-17866795 ] Kevin Lam commented on FLINK-22748: --- https://github.com/apache/flink/pull/16142#issuec

[jira] [Commented] (FLINK-22748) Allow dynamic target topic selection in SQL Kafka sinks

[ https://issues.apache.org/jira/browse/FLINK-22748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17866771#comment-17866771 ] Kevin Lam commented on FLINK-22748: --- [~nicholasjiang] are you still working on this? I

[jira] [Updated] (FLINK-35808) Let ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG be overridable by user in KafkaSourceBuilder

[ https://issues.apache.org/jira/browse/FLINK-35808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Lam updated FLINK-35808: -- Description: This issue is a follow-up to [this mailing list discussion|https://lists.apache.org/thre

[jira] [Updated] (FLINK-35808) Let ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG be overridable by user in KafkaSourceBuilder

[ https://issues.apache.org/jira/browse/FLINK-35808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Lam updated FLINK-35808: -- Description: This issue is a follow-up to [this mailing list discussion|https://lists.apache.org/thre

[jira] [Updated] (FLINK-35808) Let ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG be overridable by user in KafkaSourceBuilder

[ https://issues.apache.org/jira/browse/FLINK-35808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Lam updated FLINK-35808: -- Description: This issue is a follow-up to [this mailing list discussion|https://lists.apache.org/thre

[jira] [Updated] (FLINK-35808) Let ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG be overridable by user in KafkaSourceBuilder

[ https://issues.apache.org/jira/browse/FLINK-35808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Lam updated FLINK-35808: -- Description: This issue is a follow-up to [this mailing list discussion|https://lists.apache.org/thre

[jira] [Created] (FLINK-35808) Let ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG be overridable by user in KafkaSourceBuilder

Kevin Lam created FLINK-35808: - Summary: Let ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG be overridable by user in KafkaSourceBuilder Key: FLINK-35808 URL: https://issues.apache.org/jira/browse/FLINK-35808

[jira] [Commented] (FLINK-31762) Subscribe to multiple Kafka topics may cause partition assignment skew

[ https://issues.apache.org/jira/browse/FLINK-31762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17852543#comment-17852543 ] Kevin Lam commented on FLINK-31762: --- Hi, I'm also experiencing this issue, added some

[jira] [Commented] (FLINK-31860) FlinkDeployments never finalize when namespace is deleted

[ https://issues.apache.org/jira/browse/FLINK-31860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825409#comment-17825409 ] Kevin Lam commented on FLINK-31860: --- Thanks [~gyfora]! Is there any consideration for

[jira] [Commented] (FLINK-31860) FlinkDeployments never finalize when namespace is deleted

[ https://issues.apache.org/jira/browse/FLINK-31860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17824083#comment-17824083 ] Kevin Lam commented on FLINK-31860: --- Hi, any updates on this issue?  It seems that [h

[jira] [Comment Edited] (FLINK-34440) Support Debezium Protobuf Confluent Format

[ https://issues.apache.org/jira/browse/FLINK-34440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817076#comment-17817076 ] Kevin Lam edited comment on FLINK-34440 at 2/13/24 5:00 PM:

[jira] [Commented] (FLINK-34440) Support Debezium Protobuf Confluent Format

[ https://issues.apache.org/jira/browse/FLINK-34440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817076#comment-17817076 ] Kevin Lam commented on FLINK-34440: --- I just added this Jira issue, following the [Cont

[jira] [Created] (FLINK-34440) Support Debezium Protobuf Confluent Format

Kevin Lam created FLINK-34440: - Summary: Support Debezium Protobuf Confluent Format Key: FLINK-34440 URL: https://issues.apache.org/jira/browse/FLINK-34440 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-24257) Using Stateful Blue/Green Deployment to handle Application Evolvement

[ https://issues.apache.org/jira/browse/FLINK-24257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17725851#comment-17725851 ] Kevin Lam commented on FLINK-24257: --- Hi! Interested in this, and blue-green deployment

[jira] [Commented] (FLINK-25416) Build unified Parquet BulkFormat for both Table API and DataStream API

[ https://issues.apache.org/jira/browse/FLINK-25416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504393#comment-17504393 ] Kevin Lam commented on FLINK-25416: --- Hi Jing Ge! Thanks for the quick response.  As f

[jira] [Commented] (FLINK-21406) Add AvroParquetFileRecordFormat

[ https://issues.apache.org/jira/browse/FLINK-21406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504379#comment-17504379 ] Kevin Lam commented on FLINK-21406: --- Hi, is there a ticket for someone to implement sp

[jira] [Commented] (FLINK-25416) Build unified Parquet BulkFormat for both Table API and DataStream API

[ https://issues.apache.org/jira/browse/FLINK-25416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503710#comment-17503710 ] Kevin Lam commented on FLINK-25416: --- Hi, has there been any updates to this issue? I'm