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

XML

Word

Printable

JSON

Details

Type: Technical Debt
Status: Closed
Priority: Major
Resolution: Not A Problem
Affects Version/s: 1.15.0
Fix Version/s: None
Component/s: API / DataSet, API / DataStream, API / Python, Connectors / ElasticSearch, Connectors / Kafka, Table SQL / API
Labels:
None
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

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

Attachments

Activity

People

Assignee:: Unassigned

Reporter:: ela demir

Votes:: 0 Vote for this issue

Watchers:: 3 Start watching this issue

Dates

Created:: 01/Jul/22 08:17

Updated:: 04/Jul/22 01:49

Resolved:: 01/Jul/22 08:22