How to use Flink 2.x to run the example

Dear maintainers,
I am trying to use flink2.x python api to run the example. But it looks like the pyproject.toml is using Flink1.20 ("confluent-flink-table-api-python-plugin>=1.20.52").
I checked the pypi of confluent, and tried to install `python -m pip install cp_pyflink` which seems to contain the support of Flink2.x
But it failed to run commands like `from pyflink.table.confluent import ConfluentSettings, ConfluentTools`

Is there anything wrong in my experiment?

My env:
python 3.10 with following packages:
```txt
./venv/bin/python -m pip list
Package Version
------------------------- -----------
anaconda-anon-usage 0.4.4
apache-beam 2.61.0
archspec 0.2.3
async-timeout 5.0.1
attrs 25.4.0
avro 1.12.1
avro-python3 1.10.2
boltons 23.0.0
Brotli 1.0.9
certifi 2024.7.4
cffi 1.16.0
charset-normalizer 3.3.2
cloudpickle 2.2.1
conda 24.7.1
conda-content-trust 0.2.0
conda-libmamba-solver 24.7.0
conda-package-handling 2.3.0
conda_package_streaming 0.10.0
cp-pyflink 2.1.1.1
cp-pyflink-libraries 2.1.1.1
crcmod 1.7
cryptography 42.0.5
dill 0.3.1.1
distro 1.9.0
dnspython 2.8.0
docopt 0.6.2
fastavro 1.12.1
fasteners 0.20
find_libpython 0.5.0
frozendict 2.4.2
grpcio 1.65.5
hdfs 2.7.3
httplib2 0.22.0
idna 3.7
jsonpatch 1.33
jsonpickle 3.4.2
jsonpointer 2.1
jsonschema 4.26.0
jsonschema-specifications 2025.9.1
libmambapy 1.5.8
menuinst 2.1.2
numpy 1.24.4
objsize 0.6.1
orjson 3.11.4
packaging 24.1
pandas 2.2.3
pemja 0.4.1
pip 24.2
platformdirs 3.10.0
pluggy 1.0.0
proto-plus 1.26.1
protobuf 5.29.6
py4j 0.10.9.7
pyarrow 11.0.0
pyarrow-hotfix 0.7
pycosat 0.6.6
pycparser 2.21
pydot 1.4.2
PyJWT 2.11.0
pymongo 4.15.3
pyparsing 3.2.5
PySocks 1.7.1
python-dateutil 2.9.0.post0
pytz 2025.2
PyYAML 6.0.3
redis 5.3.1
referencing 0.37.0
regex 2025.10.23
requests 2.32.3
rpds-py 0.30.0
ruamel.yaml 0.18.16
ruamel.yaml.clib 0.2.14
setuptools 72.1.0
six 1.17.0
sortedcontainers 2.4.0
tqdm 4.66.4
truststore 0.8.0
typing_extensions 4.15.0
tzdata 2025.2
urllib3 2.2.2
wheel 0.43.0
zstandard 0.22.0
```

Thanks.