我正在使用Apache v1.6.0,我试图写到中托管的ElasticSearchv6.4.0。在验证到弹性云集群时,我遇到了问题。> httpHosts = new ArrayList<>();
// use a ElasticsearchSink.BuilderesSinkBuilder.setBulkFlushMaxAction
我的目标是建立一个高吞吐量集群,使用Kafka作为源,使用Flink作为流处理引擎。这就是我所做的。<WORKER_IP_ADDR>两个节点上的flink设置位于同名文件夹中。KafkaSource<String>(kafkaUrl,kafkaTopic, new SimpleStringSchema()));
strea
FlinkKafkaConsumer09<String>("rdf-new", new SimpleStringSchema(), parameterTool.getProperties()));stream.print();}}
我用相同的代码在intellij中创建了一个独立的项目(有它自己的pom),而且它运行得很好,但是由于我需要在另一个项目中使用代码maven模块