We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 25a4c67 commit 29e81faCopy full SHA for 29e81fa
1 file changed
README.md
@@ -1,4 +1,4 @@
1
-## flink-mqtt-connector
+## flink-connector-mqtt
2
3
基于flink最新的[FLIP-27](https://cwiki.apache.org/confluence/display/FLINK/FLIP-27%3A+Refactor+Source+Interface)架构对MQTT
4
connector的实现,主要特性如下:
@@ -14,22 +14,16 @@ connector的实现,主要特性如下:
14
- flink版本支持1.17.1及以上版本
15
16
## 使用方法
17
-
18
1. 引入依赖
19
-maven:
20
```xml
21
<dependency>
22
<groupId>com.github.davidfantasy.flink.connector.mqtt</groupId>
23
<artifactId>flink-connector-mqtt</artifactId>
24
<version>1.0.0</version>
25
</dependency>
26
```
27
-gradle:
28
-```gradle
29
-implementation 'com.github.davidfantasy.flink.connector.mqtt:flink-connector-mqtt:1.0.0
30
-```
31
-2. 示例代码:
32
+2. 示例代码:
33
```java
34
public class MqttSourceTest {
35
0 commit comments