Skip to content

Pull requests: apache/flink-connector-kafka

New pull request New
28 Open 110 Closed
28 Open 110 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
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Pull requests list

[FLINK-36821] Update to Kafka 3.9.0 component=Connectors/Kafka
#138 opened Nov 29, 2024 by tomncooper Loading…
1
[FLINK-36817] Introduce KafkaConsumerFactory component=Connectors/Kafka
#137 opened Nov 28, 2024 by lkokhreidze Loading…
3
[FLINK-36780] Kafka source disables partition discovery unexpectedly component=Connectors/Kafka
#136 opened Nov 23, 2024 by liuml07 Loading…
4
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…
[FLINK-33265] Support source parallelism setting for Kafka connector component=Connectors/Kafka component=Documentation
#134 opened Nov 16, 2024 by X-czh Loading…
14
[FLINK-36630][Connectors/Kafka] Wrap consumer.position in retryOnWakeup component=Connectors/Kafka
#133 opened Nov 8, 2024 by trompa Loading…
1
[FLINK-XXXXX][Connectors/Kafka]bump kafka client version to 3.5.2 to use KIP-881 (client.rack) component=Connectors/Kafka
#120 opened Sep 20, 2024 by hansh0801 Loading…
1
[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…
1
[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…
1
[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
[hotfix][docs] refer to kafka_sasl_ssl_example in the docs component=Documentation
#67 opened Nov 10, 2023 by 531651225 Loading…
@MartijnVisser
2
[FLINK-25538][Connectors/Kafka] Migration flink-connector-kafka from junit4 to junit5 component=Connectors/Kafka
#66 opened Nov 9, 2023 by victor09091 Loading…
4
[hotfix][docs] Fix scan.bounded.mode missing forward options component=Connectors/Kafka component=Documentation
#60 opened Oct 13, 2023 by Tan-JiaLiang Loading…
@MartijnVisser
2
[FLINK-32893][Connectors/Kafka] Allow the clientid to be fully configurable component=Connectors/Kafka
#45 opened Aug 23, 2023 by bdbene Loading…
6
ProTip! Filter pull requests by the default branch with base:main.