Skip to content

Pull requests: apache/flink-connector-kafka

New pull request New
32 Open 145 Closed
32 Open 145 Closed
Author
Filter by author
Loading
Label
Filter by label
Loading
Use alt + click/return to exclude labels
or ⇧ + click/return for logical OR
Projects
Filter by project
Loading
Milestones
Filter by milestone
Loading
Reviews
Filter by reviews
No reviews Review required Approved review Changes requested
Assignee
Filter by who’s assigned
Assigned to nobody Loading
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Pull requests list

[FLINK-37863] add DynamicKafkaSource interface
#177 opened May 28, 2025 by lgo • Draft
3 tasks
3
[FLINK-32609] Support Projection Pushdown component=Connectors/Kafka
#174 opened May 9, 2025 by fqshopify • Draft
7 tasks
[FLINK-34466][LINEAGE] Support dataset type facet for Avro component=Connectors/Kafka
#171 opened Apr 16, 2025 by pawel-big-lebowski Loading…
1
[FLINK-37650] Enable Stale PR Github action component=BuildSystem
#169 opened Apr 10, 2025 by tomncooper Loading…
[FLINK-37583] Upgrade to Kafka 4.0.0 client. component=Connectors/Kafka component=Documentation
#161 opened Mar 28, 2025 by tomncooper Loading…
13
[FLINK-37366] Allow configurable retry for Kafka topic metadata fetch component=Connectors/Kafka
#155 opened Feb 26, 2025 by suez1224 Loading…
5
[FLINK-XXX] Add set_deserializer method to Python KafkaSourceBuilder
#148 opened Jan 13, 2025 by fqaiser94 • Draft
1
fix DynamicKafkaRecordSerializationSchema, add serialVersionUID component=Connectors/Kafka
#143 opened Dec 23, 2024 by lwjhn Loading…
2
[FLINK-36906] Optimize the logic for determining if a split is finished component=Connectors/Kafka
#141 opened Dec 16, 2024 by xiaochen-zhou Loading…
3
[FLINK-36817] Introduce KafkaConsumerFactory component=Connectors/Kafka
#137 opened Nov 28, 2024 by lkokhreidze Loading…
3
Bump org.apache.kafka:kafka-clients from 3.4.0 to 3.7.1 dependencies Pull requests that update a dependency file
#135 opened Nov 19, 2024 by dependabot bot Loading…
2
[FLINK-28842] add client.id.prefix for kafka sink component=Connectors/Kafka
#118 opened Sep 7, 2024 by rich-c-shop • Draft
1
[FLINK-35870] Change DEFAULT_KAFKA_TRANSACTION_TIMEOUT in KafkaSinkBuilder component=Connectors/Kafka
#110 opened Jul 28, 2024 by twosom Loading…
2
[FLINK-25538][Connectors/Kafka] Migration flink-connector-kafka from Junit4 to Junit5 component=Connectors/Kafka
#106 opened Jun 19, 2024 by morazow Loading…
8
[FLINK-35631] enable dynamic partition discovery by default in CONTINUOUS_UNBOUNDED mode component=Connectors/Kafka
#105 opened Jun 19, 2024 by elon-X Loading…
[FLINK-35632] Fix the example provided in the kafkaSource documentation for topic regex subscription component=Documentation
#104 opened Jun 18, 2024 by elon-X Loading…
1
[FLINK-35404] Report all metrics of KafkaConsumer in new Kafka source component=Connectors/Kafka
#103 opened May 20, 2024 by hmit Loading…
3
[FLINK-35283] PoC for supporting unique Kafka producer client ids component=Connectors/Kafka
#101 opened May 2, 2024 by francis-a Loading…
@AHeise
6
[FLINK-34127] Upgrade to flink-connector-parent 1.1.0 to exclude runn…
#98 opened Apr 26, 2024 by mas-chen Loading…
1
[FLINK-34995] flink kafka connector source stuck when partition leade… component=Connectors/Kafka
#91 opened Apr 7, 2024 by yanspirit Loading…
3
[FLINK-34996][Connectors/Kafka] Use UserCodeCL to instantiate Deserializer component=Connectors/Kafka
#89 opened Apr 3, 2024 by hugogu Loading…
21
FLINK-31361 - Added the right shaded dependency for SQL client connector for kafka - Updated kafka.md component=Documentation
#88 opened Mar 27, 2024 by diptimanr Loading…
3
[FLINK-25509][connector/kafka] Add RecordEvaluator to dynamically stop source based on de-serialized records component=Connectors/Kafka
#76 opened Jan 9, 2024 by ruanhang1993 Loading…
13
[FLINK-33466][Connectors/Kafka]: Bounded Kafka source never finishes after restore from savepoint component=Connectors/Kafka
#71 opened Dec 7, 2023 by jwtryg Loading…
4
[FLINK-33545][Connectors/Kafka] KafkaSink implementation can cause dataloss during broker issue when not using EXACTLY_ONCE if there's any batching component=Connectors/Kafka
#70 opened Nov 30, 2023 by hhktseng Loading…
@AHeise
20
ProTip! Follow long discussions with comments:>50.