You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@rocketmq.apache.org by zh...@apache.org on 2022/11/24 08:30:39 UTC

[rocketmq-connect] branch master updated (4eead0c8 -> d8f25106)

This is an automated email from the ASF dual-hosted git repository.

zhoubo pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git


    from 4eead0c8 support vscode ide (#381)
     add d8f25106 [ISSUE #373] Add elasticsearch sink connector (#374)

No new revisions were added by this update.

Summary of changes:
 .../rocketmq-connect-elasticsearch/README.md       |  21 +-
 connectors/rocketmq-connect-elasticsearch/pom.xml  |   2 +-
 .../elasticsearch/config/ElasticsearchConfig.java  |  39 +++-
 .../config/ElasticsearchConstant.java              |   2 +
 .../connector/ElasticsearchSinkConnector.java}     |  46 +++--
 .../connector/ElasticsearchSinkTask.java           | 213 +++++++++++++++++++++
 .../connector/ElasticsearchSourceTask.java         |  22 ++-
 .../replicator/source/ElasticsearchQuery.java      |   9 +
 8 files changed, 327 insertions(+), 27 deletions(-)
 copy connectors/{rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceConnector.java => rocketmq-connect-elasticsearch/src/main/java/org/apache/rocketmq/connect/elasticsearch/connector/ElasticsearchSinkConnector.java} (67%)
 create mode 100644 connectors/rocketmq-connect-elasticsearch/src/main/java/org/apache/rocketmq/connect/elasticsearch/connector/ElasticsearchSinkTask.java