Arvid Heise
Arvid Heise
We should additionally provide a version with guava shaded.
Automation of #15
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
## What is the purpose of the change Sinks so far retried asynchronously to increase commit throughput in case of temporary issues. However, the contract of notifyCheckpointCompleted states that checkpoints...
## What is the purpose of the change [FLINK-36287](https://issues.apache.org/jira/browse/FLINK-36287) disabled UC for all inter-sink connections to adhere to the contract of notifyCheckpointCompleted. This allows us to remove some special casing...
FLINK-38453 broke the threading model of KafkaEnumerator by accessing some of the data structures from the worker thread without synchronization. The migration path also triggers NPE. This commit partially reverts...
Update Kafka connector docs for 4.0.0