iotdb
iotdb copied to clipboard
kafka写入Demo
Demo说明
能够按照日志版协议、乱序协议写入kafka,有完善的格式检测,能够返回status,已经完成测试。 如要测试功能请打开本机kafka,端口为9092,创建IoTDB的topic或在server.properties中设置auto.create.topics.enable=true
This PR has:
- [x] been self-reviewed.
- [ ] concurrent read
- [ ] concurrent write
- [ ] concurrent read and write
- [ ] added documentation for new or modified features or behaviors.
- [ ] added Javadocs for most classes and all non-trivial methods.
- [ ] added or updated version, license, or notice information
- [ ] added comments explaining the "why" and the intent of the code wherever would not be obvious for an unfamiliar reader.
- [ ] added unit tests or modified existing tests to cover new code paths, ensuring the threshold for code coverage.
- [ ] added integration tests.
- [ ] been tested in a test IoTDB cluster.