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
