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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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:
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
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
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
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
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
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
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
赵富午 created FLINK-20106:
---
Summary: flink 1.10 kafka
connector通用版本,使用FlinkFixedPartitioner分区器,获取不到parallelInstanceId,parallelInstanceId始终是0,导致数据都被sink到一个kafka
分区上了
Key: FLINK-20106
URL: https://issues.apache.org/jira
201 - 228 of 228 matches
Mail list logo