flink-connector-kafka

flink-connector-kafka copied to clipboard

[FLINK-22748] Allow dynamic target topic selection in SQL Kafka sinks

4

## What is the purpose of the change Allows writing to different Kafka topics based on the `topic` metadata column value in SQL, and updates the Table API's `KafkaDynamicSink` to...

klam-shop

[FLINK-34467] bump flink version to 1.20.0

17

Update Flink version 1.20.0 to prepare support Lineage integration

HuangZhenQiu

[FLINK-35870] Change DEFAULT_KAFKA_TRANSACTION_TIMEOUT in KafkaSinkBuilder

1

change `DEFAULT_KAFKA_TRANSACTION_TIMEOUT` in `KafkaSinkBuilder` class. The default value is 15 minutes, as shown in the official Kakfa documentation. So I changed it from 1 hour to 15 minutes and added...

twosom

[FLINK-25538][Connectors/Kafka] Migration flink-connector-kafka from Junit4 to Junit5

3

### What is the purpose of the change - [JUnit5 Migration] Module: [flink-connector-kafka](https://github.com/apache/flink-connector-kafka), [FLINK-25538](https://issues.apache.org/jira/browse/FLINK-25538). ### Brief change log - Updated Junit4 test packages to Junit5 test packages. - This pull...

morazow

[FLINK-35632] Fix the example provided in the kafkaSource documentation for topic regex subscription

1

Fix the example provided in the kafkaSource documentation for topic regex subscription see the issue: https://issues.apache.org/jira/browse/FLINK-35632

elon-X

In this subtask of FLIP-288, FLINK-32020, it can be seen that automatic partition discovery is supposed to be enabled by default, but it actually isn't. For details, see issue: FLINK-35631.

elon-X

[FLINK-35404] Report all metrics of KafkaConsumer in new Kafka source

1

hmit

[FLINK-35109] Bump to Flink 1.19 and support Flink 1.20

1

Also - adds the migration support tests up to 1.20. - bumps Kafka-client to 3.6.2 - various test cases that become flaky with the bumps

AHeise

[FLINK-XXXXX][Connectors/Kafka]bump kafka client version to 3.5.2 to use KIP-881 (client.rack)

1

To use the Rack-aware Partition Assignment for Kafka Consumers ([KIP-881](https://cwiki.apache.org/confluence/display/KAFKA/KIP-881%3A+Rack-aware+Partition+Assignment+for+Kafka+Consumers)) introduced in [confluent blog](https://www.confluent.io/blog/introducing-apache-kafka-3-5/), upgrade the kafka client version used by flink-connector-kafka to version 3.5.2.

hansh0801

[FLINK-28842] add client.id.prefix for kafka sink

1

https://issues.apache.org/jira/browse/FLINK-28842 fix `javax.management.InstanceAlreadyExistsException` for kafka sink similar to https://github.com/apache/flink-connector-kafka/pull/118 and address the producer pool comments

rich-c-shop