Re: Flink OpenSearch connector version supported for Flink 1.20

Refer to the discussion before, Flink OpenSearch Connector version 1.x is suitable for lists.apache.org

RE: Flink OpenSearch connector version supported for Flink 1.20

Hi Yanqaun We are doing an upgrade from Flink 1.16 to 1.20. With Flink 1.16, we were using Flink OpenSearch Connector version 1.0.1-1.16 with Flink 1.20 and OpenSearch version 2.9.0. While doing an upgrade of Flink 1.16 to Flink 1.20, is it necessary to upgrade Flink OpenSearch Connector (org

Re: Flink OpenSearch connector version supported for Flink 1.20

Hi, What about using org.apache.flink:flink-sql-connector-opensearch2:2.0.0-1.19, this version supported Flink 1.20 and Opensearch2. https://mvnrepository.com/artifact/org.apache.flink/flink-sql-connector-opensearch2/2.0.0-1.19 > 2025年1月28日 13:27，Swati Jain Goyal via user 写道： > > 1.0.1-1.16

Flink OpenSearch connector version supported for Flink 1.20

Hi Can flink OpenSearch Connector version 1.0.1-1.16 be used with Flink 1.20 and OpenSearch version 2.9.0? BR, Swati

Dynamic Kafka Properties

I've recently started to enable rack awareness in my sources following this: https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/datastream/kafka/#rackid E.g., ```java .setRackIdSupplier(() -> System.getenv("TM_NODE_AZ")) ``` This approach allows to decouple the AZ between jo