[jira] [Created] (FLINK-32451) Refactor Confluent Schema Registry E2E Tests to remove Kafka connector dependency

2023-06-27 Thread Mason Chen (Jira)
Mason Chen created FLINK-32451: -- Summary: Refactor Confluent Schema Registry E2E Tests to remove Kafka connector dependency Key: FLINK-32451 URL: https://issues.apache.org/jira/browse/FLINK-32451

[jira] [Created] (FLINK-35007) Update Flink Kafka connector to support 1.19 and test 1.20-SNAPSHOT

2024-04-04 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-35007: -- Summary: Update Flink Kafka connector to support 1.19 and test 1.20-SNAPSHOT Key: FLINK-35007 URL: https://issues.apache.org/jira/browse/FLINK-35007 Project

[jira] [Created] (FLINK-35008) Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.0 for Flink Kafka connector

2024-04-04 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-35008: -- Summary: Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.0 for Flink Kafka connector Key: FLINK-35008 URL: https://issues.apache.org/jira/browse/FLINK-35008

[jira] [Created] (FLINK-35034) codegen compile error raised when use kafka connector and protobuf format

2024-04-07 Thread yufeng.sun (Jira)
yufeng.sun created FLINK-35034: -- Summary: codegen compile error raised when use kafka connector and protobuf format Key: FLINK-35034 URL: https://issues.apache.org/jira/browse/FLINK-35034 Project: Flink

[jira] [Created] (FLINK-35109) Drop support for Flink 1.17 and 1.18 in Flink Kafka connector

2024-04-15 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-35109: -- Summary: Drop support for Flink 1.17 and 1.18 in Flink Kafka connector Key: FLINK-35109 URL: https://issues.apache.org/jira/browse/FLINK-35109 Project: Flink

Kafka Connector Consulting: Why there is no limit size of Kafka producer pool in KafkaWriter

2024-07-09 Thread Rascal Wu
Hi, May I consult one question about why there is no limit size of `producerPool` in KafkaWriter. It seems that the current logical will create a new producer during create KafkaWriter and start checkpoint(snapshotState been invoked) if the producer pool is empty, and then add the producer into po

[jira] [Created] (FLINK-15262) kafka connector doesn't read from beginning immediately when 'connector.startup-mode' = 'earliest-offset'

2019-12-15 Thread Bowen Li (Jira)
Bowen Li created FLINK-15262: Summary: kafka connector doesn't read from beginning immediately when 'connector.startup-mode' = 'earliest-offset' Key: FLINK-15262 URL: https://issues.apa

[jira] [Created] (FLINK-18602) Support specific offset for topic list for kafka connector in table api

2020-07-14 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-18602: - Summary: Support specific offset for topic list for kafka connector in table api Key: FLINK-18602 URL: https://issues.apache.org/jira/browse/FLINK-18602 Project

[jira] [Created] (FLINK-18017) improve Kafka connector to handle record deserialization exception and report related metrics

2020-05-28 Thread Yu Yang (Jira)
Yu Yang created FLINK-18017: --- Summary: improve Kafka connector to handle record deserialization exception and report related metrics Key: FLINK-18017 URL: https://issues.apache.org/jira/browse/FLINK-18017

[jira] [Created] (FLINK-30052) Move existing Kafka connector code from Flink repo to dedicated Kafka repo

2022-11-17 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-30052: -- Summary: Move existing Kafka connector code from Flink repo to dedicated Kafka repo Key: FLINK-30052 URL: https://issues.apache.org/jira/browse/FLINK-30052

[jira] [Created] (FLINK-32743) Flink kafka connector source can directly parse data collected from kafka-connect

2023-08-03 Thread Xiaojian Sun (Jira)
Xiaojian Sun created FLINK-32743: Summary: Flink kafka connector source can directly parse data collected from kafka-connect Key: FLINK-32743 URL: https://issues.apache.org/jira/browse/FLINK-32743

[jira] [Created] (FLINK-35011) The change in visibility of MockDeserializationSchema cause compilation failure in kafka connector

2024-04-04 Thread Jiabao Sun (Jira)
Jiabao Sun created FLINK-35011: -- Summary: The change in visibility of MockDeserializationSchema cause compilation failure in kafka connector Key: FLINK-35011 URL: https://issues.apache.org/jira/browse/FLINK-35011

[jira] [Created] (FLINK-10872) Extend SQL client end-to-end to test KafkaTableSink for kafka connector 0.11

2018-11-13 Thread vinoyang (JIRA)
vinoyang created FLINK-10872: Summary: Extend SQL client end-to-end to test KafkaTableSink for kafka connector 0.11 Key: FLINK-10872 URL: https://issues.apache.org/jira/browse/FLINK-10872 Project: Flink

[jira] [Created] (FLINK-10922) Refactor the placement of the Flink Kafka connector end to end test module

2018-11-18 Thread vinoyang (JIRA)
vinoyang created FLINK-10922: Summary: Refactor the placement of the Flink Kafka connector end to end test module Key: FLINK-10922 URL: https://issues.apache.org/jira/browse/FLINK-10922 Project: Flink

[jira] [Created] (FLINK-2744) Reduce number of concurrent test forks to 1 for the Kafka connector project

2015-09-23 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2744: --- Summary: Reduce number of concurrent test forks to 1 for the Kafka connector project Key: FLINK-2744 URL: https://issues.apache.org/jira/browse/FLINK-2744 Project

[jira] [Created] (FLINK-4004) Do not pass custom flink kafka connector properties to Kafka to avoid warnings

2016-06-01 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-4004: - Summary: Do not pass custom flink kafka connector properties to Kafka to avoid warnings Key: FLINK-4004 URL: https://issues.apache.org/jira/browse/FLINK-4004

[jira] [Created] (FLINK-6923) Kafka connector needs to expose information about in-flight record in AbstractFetcher base class

2017-06-14 Thread Zhenzhong Xu (JIRA)
Zhenzhong Xu created FLINK-6923: --- Summary: Kafka connector needs to expose information about in-flight record in AbstractFetcher base class Key: FLINK-6923 URL: https://issues.apache.org/jira/browse/FLINK-6923

[jira] [Created] (FLINK-25344) flink kafka connector Property group.id is required when using committed offset for offsets initializer

2021-12-16 Thread jingzi (Jira)
jingzi created FLINK-25344: -- Summary: flink kafka connector Property group.id is required when using committed offset for offsets initializer Key: FLINK-25344 URL: https://issues.apache.org/jira/browse/FLINK-25344

[jira] [Created] (FLINK-24544) Failure when using Kafka connector in Table API with Avro and Confluent schema registry

2021-10-14 Thread Francesco Guardiani (Jira)
Francesco Guardiani created FLINK-24544: --- Summary: Failure when using Kafka connector in Table API with Avro and Confluent schema registry Key: FLINK-24544 URL: https://issues.apache.org/jira/browse/FLINK

[jira] [Created] (FLINK-28622) Can't restore a flink job that uses Table API and Kafka connector with savepoint

2022-07-21 Thread Nathan (Jira)
Nathan created FLINK-28622: -- Summary: Can't restore a flink job that uses Table API and Kafka connector with savepoint Key: FLINK-28622 URL: https://issues.apache.org/jira/browse/FLINK-28622 Project:

[jira] [Created] (FLINK-33191) Kafka Connector should directly depend on 3rd-party libs instead of flink-shaded repo

2023-10-04 Thread Jing Ge (Jira)
Jing Ge created FLINK-33191: --- Summary: Kafka Connector should directly depend on 3rd-party libs instead of flink-shaded repo Key: FLINK-33191 URL: https://issues.apache.org/jira/browse/FLINK-33191 Project

[jira] [Created] (FLINK-33484) Flink Kafka Connector Offset Lag Issue with Transactional Data and Read Committed Isolation Level

2023-11-08 Thread Darcy Lin (Jira)
Darcy Lin created FLINK-33484: - Summary: Flink Kafka Connector Offset Lag Issue with Transactional Data and Read Committed Isolation Level Key: FLINK-33484 URL: https://issues.apache.org/jira/browse/FLINK-33484

[jira] [Created] (FLINK-16334) flink-sql kafka-connector support ignore the invalid data during parsing bytes to json row

2020-02-28 Thread roncenzhao (Jira)
roncenzhao created FLINK-16334: -- Summary: flink-sql kafka-connector support ignore the invalid data during parsing bytes to json row Key: FLINK-16334 URL: https://issues.apache.org/jira/browse/FLINK-16334

[jira] [Created] (FLINK-6998) Kafka connector needs to expose metrics for failed/successful offset commits in the Kafka Consumer callback

2017-06-23 Thread Zhenzhong Xu (JIRA)
Zhenzhong Xu created FLINK-6998: --- Summary: Kafka connector needs to expose metrics for failed/successful offset commits in the Kafka Consumer callback Key: FLINK-6998 URL: https://issues.apache.org/jira/browse

[jira] [Created] (FLINK-15552) SQL Client can not correctly create kafka table using --library to indicate a kafka connector directory

2020-01-10 Thread Terry Wang (Jira)
Terry Wang created FLINK-15552: -- Summary: SQL Client can not correctly create kafka table using --library to indicate a kafka connector directory Key: FLINK-15552 URL: https://issues.apache.org/jira/browse/FLINK

[jira] [Created] (FLINK-26115) Multiple Kafka connector tests failed due to The topic metadata failed to propagate to Kafka broker

2022-02-14 Thread Yun Gao (Jira)
Yun Gao created FLINK-26115: --- Summary: Multiple Kafka connector tests failed due to The topic metadata failed to propagate to Kafka broker Key: FLINK-26115 URL: https://issues.apache.org/jira/browse/FLINK-26115

[jira] [Created] (FLINK-16865) 【Flink Kafka Connector】Restore from Savepoint，if add new Kafka topic，Flink will consume the new topic from earlist，it may cause duplicate data sink

2020-03-30 Thread zhisheng (Jira)
zhisheng created FLINK-16865: Summary: 【Flink Kafka Connector】Restore from Savepoint，if add new Kafka topic，Flink will consume the new topic from earlist，it may cause duplicate data sink Key: FLINK-16865 URL: https

[jira] [Created] (FLINK-20106) flink 1.10 kafka connector通用版本，使用FlinkFixedPartitioner分区器，获取不到parallelInstanceId，parallelInstanceId始终是0，导致数据都被sink到一个kafka 分区上了

2020-11-12 Thread Jira
赵富午 created FLINK-20106: --- Summary: flink 1.10 kafka connector通用版本，使用FlinkFixedPartitioner分区器，获取不到parallelInstanceId，parallelInstanceId始终是0，导致数据都被sink到一个kafka 分区上了 Key: FLINK-20106 URL: https://issues.apache.org/jira

<    1   2   3