Re: [DISCUSS] FLINK-34440 Support Debezium Protobuf Confluent Format

2024-03-11 Thread Anupam Aggarwal
Hi Kevin, Thanks for starting the discussion on this. I will be working on contributing this feature back (This was developed by Dawid Wysakowicz and others at Confluent). I have opened a (very initial) draft PR here https://github.com/apache/flink/pull/24482 with our current implementation. Than

Re: [DISCUSS] FLINK-34440 Support Debezium Protobuf Confluent Format

2024-03-13 Thread Anupam Aggarwal
y, so one approach > would be to use the subject to look up the most recent version, and use > that to evolve the field ids correctly. > > > On Tue, Mar 12, 2024 at 2:33 AM Anupam Aggarwal > > wrote: > > > Hi Kevin, > > > > Thanks for starting the discussion on

Re: [DISCUSS] FLINK-34440 Support Debezium Protobuf Confluent Format

2024-03-27 Thread Anupam Aggarwal
Thanks Kevin, I will pick this up more actively starting early next week. On Wed, Mar 27, 2024 at 1:36 AM Kevin Lam wrote: > Thanks Anupam! Looking forward to it. > > On Thu, Mar 14, 2024 at 1:50 AM Anupam Aggarwal > > wrote: > > > Hi Kevin, > > > >

Re: [DISCUSS] FLINK-34440 Support Debezium Protobuf Confluent Format

2024-04-13 Thread Anupam Aggarwal
34440 Support Debezium Protobuf > Confluent Format > Thanks Anupam! Looking forward to it. > > On Thu, Mar 14, 2024 at 1:50 AM Anupam Aggarwal > > wrote: > > > Hi Kevin, > > > > Thanks, these are some great points. > > Just to clarify, I do agree that the su

Re: [DISCUSS] FLINK-34440 Support Debezium Protobuf Confluent Format

2024-04-18 Thread Anupam Aggarwal
Serilization; to prevent confusion with the deserialization > case. We could have the schema as you suggest so we are compatible with the > confluent avro format. > > > WDYT? > Kind regards, David. > > > From: Anupam Aggarwal > Date: Saturday, 13 April 2024 at 16:08 >

[jira] [Created] (FLINK-35593) Apache Kubernetes Operator Docker image does not contain Apache LICENSE

2024-06-13 Thread Anupam Aggarwal (Jira)
Anupam Aggarwal created FLINK-35593: --- Summary: Apache Kubernetes Operator Docker image does not contain Apache LICENSE Key: FLINK-35593 URL: https://issues.apache.org/jira/browse/FLINK-35593

[jira] [Created] (FLINK-35800) Update chinese documentation for json_(un)quote function

2024-07-09 Thread Anupam Aggarwal (Jira)
Anupam Aggarwal created FLINK-35800: --- Summary: Update chinese documentation for json_(un)quote function Key: FLINK-35800 URL: https://issues.apache.org/jira/browse/FLINK-35800 Project: Flink

[jira] [Created] (FLINK-36920) Update org.quartz-schedule:quartz

2024-12-17 Thread Anupam Aggarwal (Jira)
Anupam Aggarwal created FLINK-36920: --- Summary: Update org.quartz-schedule:quartz Key: FLINK-36920 URL: https://issues.apache.org/jira/browse/FLINK-36920 Project: Flink Issue Type

[jira] [Created] (FLINK-37078) Update jackson-mapper-asl dependency

2025-01-08 Thread Anupam Aggarwal (Jira)
Anupam Aggarwal created FLINK-37078: --- Summary: Update jackson-mapper-asl dependency Key: FLINK-37078 URL: https://issues.apache.org/jira/browse/FLINK-37078 Project: Flink Issue Type: Bug