File tree 1 file changed +6
-2
lines changed
1 file changed +6
-2
lines changed Original file line number Diff line number Diff line change 4
4
:project-owner: redis-field-engineering
5
5
:project-name: redis-flink-connector
6
6
:project-group: com.redis
7
- :project-version: 0.0.5
7
+ :project-version: 0.0.7
8
8
:dist-repo-name: redis-flink-connector-dist
9
9
10
10
The Redis Flink Connector is a highly performant, scalable Flink Source and Sink
@@ -60,7 +60,9 @@ The following table describes the fields in that class:
60
60
| `useClusterApi` | `boolean` | `false` | No
61
61
| `requireAck` | `boolean` | `true` | No
62
62
| `startingId` | `StreamEntryID` | `StreamEntryID.XGROUP_LAST_ENTRY` | No
63
- |`failedDeserializationStreamName` | `String` | `""` (empty string) | No
63
+ |`failedDeserializationStreamName` | `String` | `""` | No
64
+ |`useTls` | `boolean` | `false` | No
65
+ |`mtlsParameters` | `MtlsParameters` | `null` | No
64
66
|===
65
67
66
68
You can then initialize the Source Builder using:
@@ -100,6 +102,8 @@ The following table describes the fields in that class:
100
102
| `numPartitions` | `int` | N/A | Yes | the number of partitions
101
103
| `flushOnCheckpoint` | `boolean` | `false` | No | whether to flush writes on checkpoint
102
104
| `failedSerializationStreamName` | `String` | `""` (empty string) | No | the stream name to serialization errors to
105
+ |`useTls` | `boolean` | `false` | No | whether to use TLS
106
+ |`mtlsParameters` | `MtlsParameters` | `null` | No | parameters to use for mTLS
103
107
|===
104
108
105
109
You then have to initialize the builder and sink to it:
You can’t perform that action at this time.
0 commit comments