githublaohu

又一个是一个你们架构设计问题， 一个库，不可能支持你们这么多特许需求， 如果数据为null，直接在数据库设定默认值就行了。这么简单的啊。

抱歉，实在没看到。提交的代码里面做了写什么。与 output有啥关系？

1. 配置读取，解析，分析待完成 2. 集群测试待完成 3. 单元测试待完成 4. 一些细节点没有时间，或者有待讨论

ok，没问题。 > 最好是将 ES 的connector 独立出来，其并不依赖上游数据源，上游数据源可能是MySQL，也有可能是日志

Development, unit test and integration test have been completed. In addition to MySQL, it can be compatible with other simple data sources. The upstream MySQL source (rocketmq connect mysql and...

yes. The upstream source cannot provide the downstream data completely. Can the existing source and sink be combined to complete a business process. Connect needs an overall driver. Thank you.

1. 麻烦提供下 如果验证这个插件 2. 麻烦，说下一些配置文件的作用 1. 是否能提供下 maven的构建方式，目前整个rocketmq都是maven构建的。 3. 麻烦优化功能与结构 4. 麻烦在文件里面，写入apache 2.0协议头

按照README.md 文档里面的说明，构建项目失败。 ` > Task :compileJava /leaning/space-work/java-study/rocketmq-externals/logstash-output-rocketmq/src/main/java/org/logstashplugins/RocketMQ.java:3: 错误: 程序包co.elastic.logstash.api不存在 import co.elastic.logstash.api.Configuration; ` logstash-api这个依赖找不到

@PatrickkZ 你好，如果看下消息或者邮件，麻烦回复下。我会协助你完成这个pr。

是否应该是jdbc-connent