[FLINK-28344] How to connect flink and elasticsearch in pyflink 1.15.0?

• Type: Technical Debt
• Status: Closed
• Priority: Major
• Resolution: Not A Problem
• Affects Version/s: 1.15.0
• Component/s: API / DataSet, API / DataStream, API / Python, Connectors / ElasticSearch, Connectors / Kafka, Table SQL / API

Environment

apache-flink==1.15.0

python==3.8.0

java11

scala 2.11

elasticsearch==7.4.0

kibana==7.4.0

Language

English Python english

• Assignee: Unassigned
• Reporter: ela demir
• Created: 01/Jul/22 08:17
• Updated: 04/Jul/22 01:49
• Resolved: 01/Jul/22 08:22

Description

hello, I'm really interested in Pyflink and aim to create a project related to Kafka > Flink > ElasticSearch > Kibana.

I can consume messages from Kafka in Flink but can not find any source to connect Flink and ElasticSearch. How can I send kafka messages Flink consumed to  ElasticSearch?

My python 3.8 environment includes: apache-flink=1.15.0