我的目标是创建一个与Kafka〉Flink〉ElasticSearch〉Kibana相关的真实的处理项目。我可以在Flink中使用来自Kafka的信息，但不能连接Flink和ElasticSearch。我如何将Flink中使用的Kafka信息发送到ElasticSearch？我的python 3.8环境包括：高速缓存- Flink =1.15.0
ars1skjm1#
您可以使用Table API创建Elasticsearch Sink表：https://nightlies.apache.org/flink/flink-docs-stable/docs/dev/python/table/python_table_api_connectors/#how-to-use-connectorshttps://nightlies.apache.org/flink/flink-docs-stable/docs/connectors/table/elasticsearch/#how-to-create-an-elasticsearch-table如果您需要将DataStream转换为Table API，您可以在这里找到一些帮助：https://nightlies.apache.org/flink/flink-docs-stable/docs/dev/table/data_stream_api/
Table API
Elasticsearch Sink
1条答案
按热度按时间ars1skjm1#
您可以使用
Table API创建Elasticsearch Sink表：https://nightlies.apache.org/flink/flink-docs-stable/docs/dev/python/table/python_table_api_connectors/#how-to-use-connectors
https://nightlies.apache.org/flink/flink-docs-stable/docs/connectors/table/elasticsearch/#how-to-create-an-elasticsearch-table
如果您需要将DataStream转换为Table API，您可以在这里找到一些帮助：https://nightlies.apache.org/flink/flink-docs-stable/docs/dev/table/data_stream_api/